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/console-v2 Commit: e6c158ac5d2390eefaea4297ee72b0b2d8b510cd Parents: a0cb5bf Author: Aaron McCurry <[email protected]> Authored: Tue May 6 09:57:45 2014 -0400 Committer: Aaron McCurry <[email protected]> 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); }
