Call waitForRecoveriesToFinish(false) in the Streaming and SQL tests.

git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1706497 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Joel Bernstein 2015-10-02 22:18:58 +00:00
parent 88b43c815e
commit 04efea7e7d
4 changed files with 5 additions and 2 deletions

View File

@ -92,6 +92,7 @@ public class TestSQLHandler extends AbstractFullDistribZkTestBase {
@Test @Test
public void doTest() throws Exception { public void doTest() throws Exception {
waitForRecoveriesToFinish(false);
testPredicate(); testPredicate();
testBasicSelect(); testBasicSelect();
testBasicGrouping(); testBasicGrouping();

View File

@ -104,6 +104,8 @@ public class JdbcTest extends AbstractFullDistribZkTestBase {
@Test @Test
public void doTest() throws Exception { public void doTest() throws Exception {
waitForRecoveriesToFinish(false);
indexr(id, "0", "a_s", "hello0", "a_i", "0", "a_f", "1"); indexr(id, "0", "a_s", "hello0", "a_i", "0", "a_f", "1");
indexr(id, "2", "a_s", "hello0", "a_i", "2", "a_f", "2"); indexr(id, "2", "a_s", "hello0", "a_i", "2", "a_f", "2");
indexr(id, "3", "a_s", "hello3", "a_i", "3", "a_f", "3"); indexr(id, "3", "a_s", "hello3", "a_i", "3", "a_f", "3");

View File

@ -114,7 +114,7 @@ public class StreamExpressionTest extends AbstractFullDistribZkTestBase {
handle.clear(); handle.clear();
handle.put("timestamp", SKIPVAL); handle.put("timestamp", SKIPVAL);
waitForThingsToLevelOut(30); waitForRecoveriesToFinish(false);
del("*:*"); del("*:*");
commit(); commit();

View File

@ -1701,7 +1701,7 @@ public class StreamingTest extends AbstractFullDistribZkTestBase {
handle.clear(); handle.clear();
handle.put("timestamp", SKIPVAL); handle.put("timestamp", SKIPVAL);
waitForThingsToLevelOut(30); waitForRecoveriesToFinish(false);
del("*:*"); del("*:*");