accumulo-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bill Havanki" <bhava...@clouderagovt.com>
Subject Re: Review Request 18444: ACCUMULO-2399 Continuous* wait a bit for scanners
Date Tue, 25 Feb 2014 14:01:39 GMT


> On Feb. 25, 2014, 9:01 a.m., Bill Havanki wrote:
> > src/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousUtil.java,
line 46
> > <https://reviews.apache.org/r/18444/diff/1/?file=502880#file502880line46>
> >
> >     What if, due to the cluster environment, it always takes longer than 3 seconds?
Should the interval be configurable?
> >     
> >     How about requiring the table to be manually created first? Then this just fails
quick with a nice error "make the table and try again".

Sorry, this somehow got logged outside the correct thread.


- Bill


-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/18444/#review35398
-----------------------------------------------------------


On Feb. 24, 2014, 6:35 p.m., Mike Drob wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/18444/
> -----------------------------------------------------------
> 
> (Updated Feb. 24, 2014, 6:35 p.m.)
> 
> 
> Review request for accumulo.
> 
> 
> Bugs: ACCUMULO-2399
>     https://issues.apache.org/jira/browse/ACCUMULO-2399
> 
> 
> Repository: accumulo
> 
> 
> Description
> -------
> 
> ACCUMULO-2399 Continuous* wait a bit for scanners
> 
> When starting ContinuousIngest concurrently with consumers, many of the
> consumers would die if they came up before the table had been created.
> Make the code a bit more robust during start-up.
> 
> 
> Diffs
> -----
> 
>   src/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousBatchWalker.java
4659affc49fc7fc2519e092330dda817ccbbadcd 
>   src/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousQuery.java
c8ae6ecf9e5ef2bd51cb803cba429baaf57f3d6a 
>   src/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousScanner.java
0ac3df63a260a201544b3623d4901b355d7ea21a 
>   src/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousUtil.java
PRE-CREATION 
>   src/server/src/main/java/org/apache/accumulo/server/test/continuous/ContinuousWalk.java
7d1e7f95c7e5a7a172990322e2992e536f2725e3 
> 
> Diff: https://reviews.apache.org/r/18444/diff/
> 
> 
> Testing
> -------
> 
> Unit tests. Started processes on 3 node cluster and batch walkers did not die.
> 
> 
> Thanks,
> 
> Mike Drob
> 
>


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message