diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2016-04-07 10:51:49 -0700 |
|---|---|---|
| committer | Shixiong Zhu <shixiong@databricks.com> | 2016-04-07 10:51:49 -0700 |
| commit | 3aa7d76395a76fb804fc2f51a39c3179208c33a5 (patch) | |
| tree | 5361602e220183aa9a9f1a9bc27e81b4ebc5d5dd /sql | |
| parent | 033d8081525a7137085ec898e2426a58056ee2b8 (diff) | |
| download | spark-3aa7d76395a76fb804fc2f51a39c3179208c33a5.tar.gz spark-3aa7d76395a76fb804fc2f51a39c3179208c33a5.tar.bz2 spark-3aa7d76395a76fb804fc2f51a39c3179208c33a5.zip | |
[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 <tathagata.das1565@gmail.com>
Closes #12219 from tdas/flaky-test-fix.
Diffstat (limited to 'sql')
| -rw-r--r-- | sql/core/src/test/scala/org/apache/spark/sql/streaming/ContinuousQueryManagerSuite.scala | 4 |
1 files changed, 2 insertions, 2 deletions
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 |