You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by da...@apache.org on 2018/12/07 09:57:18 UTC
[03/37] lucene-solr:jira/http2: SOLR-12801: Don't possibly block
forever in this test in remaining spots.
SOLR-12801: Don't possibly block forever in this test in remaining spots.
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/e5281ef3
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/e5281ef3
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/e5281ef3
Branch: refs/heads/jira/http2
Commit: e5281ef3d5e36f5ad8a871818dd511fb9fbee74f
Parents: b294d84
Author: markrmiller <ma...@apache.org>
Authored: Sat Dec 1 13:02:51 2018 -0600
Committer: markrmiller <ma...@apache.org>
Committed: Sat Dec 1 13:02:58 2018 -0600
----------------------------------------------------------------------
.../solr/cloud/autoscaling/sim/TestSimDistributedQueue.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/e5281ef3/solr/core/src/test/org/apache/solr/cloud/autoscaling/sim/TestSimDistributedQueue.java
----------------------------------------------------------------------
diff --git a/solr/core/src/test/org/apache/solr/cloud/autoscaling/sim/TestSimDistributedQueue.java b/solr/core/src/test/org/apache/solr/cloud/autoscaling/sim/TestSimDistributedQueue.java
index a997571..00926f3 100644
--- a/solr/core/src/test/org/apache/solr/cloud/autoscaling/sim/TestSimDistributedQueue.java
+++ b/solr/core/src/test/org/apache/solr/cloud/autoscaling/sim/TestSimDistributedQueue.java
@@ -65,7 +65,7 @@ public class TestSimDistributedQueue extends SolrTestCaseJ4 {
assertNull(dq.poll());
dq.offer(data);
- dq.peek(true); // wait until data is definitely there before calling remove
+ dq.peek(15000); // wait until data is definitely there before calling remove
assertArrayEquals(dq.remove(), data);
assertNull(dq.poll());
@@ -90,7 +90,7 @@ public class TestSimDistributedQueue extends SolrTestCaseJ4 {
DistributedQueue dq = makeDistributedQueue(dqZNode);
assertNull(dq.peek());
- Future<String> future = executor.submit(() -> new String(dq.peek(true), UTF8));
+ Future<String> future = executor.submit(() -> new String(dq.peek(15000), UTF8));
try {
future.get(1000, TimeUnit.MILLISECONDS);
fail("TimeoutException expected");