From 3aa7d76395a76fb804fc2f51a39c3179208c33a5 Mon Sep 17 00:00:00 2001 From: Tathagata Das Date: Thu, 7 Apr 2016 10:51:49 -0700 Subject: [SQL][TESTS] Fix for flaky test in ContinuousQueryManagerSuite ## What changes were proposed in this pull request? The timeouts were lower the other timeouts in the test. Other tests were stable over the last month. ## How was this patch tested? Jenkins tests. Author: Tathagata Das Closes #12219 from tdas/flaky-test-fix. --- .../org/apache/spark/sql/streaming/ContinuousQueryManagerSuite.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'sql') diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/ContinuousQueryManagerSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/ContinuousQueryManagerSuite.scala index 33787de9da..3d69c8a187 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/streaming/ContinuousQueryManagerSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/streaming/ContinuousQueryManagerSuite.scala @@ -185,8 +185,8 @@ class ContinuousQueryManagerSuite extends StreamTest with SharedSQLContext with val q2 = stopRandomQueryAsync(100 milliseconds, withError = true) testAwaitAnyTermination( ExpectException[SparkException], - awaitTimeout = 1 seconds, - testBehaviorFor = 2 seconds) + awaitTimeout = 4 seconds, + testBehaviorFor = 6 seconds) require(!q2.isActive) // should be inactive by the time the prev awaitAnyTerm returned // All subsequent calls to awaitAnyTermination should throw the exception -- cgit v1.2.3