incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [1/2] git commit: Fixing a test that gets frozen.
Date Tue, 06 May 2014 13:58:04 GMT
Repository: incubator-blur
Updated Branches:
  refs/heads/apache-blur-0.2 db06d8f85 -> 8807238dd


Fixing a test that gets frozen.


Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/e6c158ac
Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/e6c158ac
Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/e6c158ac

Branch: refs/heads/apache-blur-0.2
Commit: e6c158ac5d2390eefaea4297ee72b0b2d8b510cd
Parents: a0cb5bf
Author: Aaron McCurry <amccurry@gmail.com>
Authored: Tue May 6 09:57:45 2014 -0400
Committer: Aaron McCurry <amccurry@gmail.com>
Committed: Tue May 6 09:57:45 2014 -0400

----------------------------------------------------------------------
 .../org/apache/blur/manager/writer/MutationQueueProcessor.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e6c158ac/blur-core/src/main/java/org/apache/blur/manager/writer/MutationQueueProcessor.java
----------------------------------------------------------------------
diff --git a/blur-core/src/main/java/org/apache/blur/manager/writer/MutationQueueProcessor.java
b/blur-core/src/main/java/org/apache/blur/manager/writer/MutationQueueProcessor.java
index f76f375..742381a 100644
--- a/blur-core/src/main/java/org/apache/blur/manager/writer/MutationQueueProcessor.java
+++ b/blur-core/src/main/java/org/apache/blur/manager/writer/MutationQueueProcessor.java
@@ -40,7 +40,8 @@ import org.apache.blur.thrift.generated.RowMutation;
 import org.apache.lucene.index.IndexWriter;
 
 public class MutationQueueProcessor implements Runnable, Closeable {
-
+  
+  private static final long TIMEOUT = TimeUnit.MILLISECONDS.toMillis(100);
   private final Log LOG = LogFactory.getLog(MutationQueueProcessor.class);
 
   private final BlockingQueue<RowMutation> _queue;
@@ -155,7 +156,7 @@ public class MutationQueueProcessor implements Runnable, Closeable {
         if (!_didMutates) {
           synchronized (_queue) {
             try {
-              _queue.wait();
+              _queue.wait(TIMEOUT);
             } catch (InterruptedException e) {
               throw new IOException(e);
             }


Mime
View raw message