Repository: spark Updated Branches: refs/heads/branch-2.3 a23f6b13e -> 3316a9d71
[SPARK-23197][DSTREAMS] Increased timeouts to resolve flakiness ## What changes were proposed in this pull request? Increased timeout from 50 ms to 300 ms (50 ms was really too low). ## How was this patch tested? Multiple rounds of tests. Author: Tathagata Das <tathagata.das1...@gmail.com> Closes #20371 from tdas/SPARK-23197. (cherry picked from commit 15adcc8273e73352e5e1c3fc9915c0b004ec4836) Signed-off-by: Tathagata Das <tathagata.das1...@gmail.com> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/3316a9d7 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/3316a9d7 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/3316a9d7 Branch: refs/heads/branch-2.3 Commit: 3316a9d7104aece977384974cf61e5ec635ad350 Parents: a23f6b1 Author: Tathagata Das <tathagata.das1...@gmail.com> Authored: Tue Jan 23 16:24:20 2018 -0800 Committer: Tathagata Das <tathagata.das1...@gmail.com> Committed: Tue Jan 23 16:24:41 2018 -0800 ---------------------------------------------------------------------- .../test/scala/org/apache/spark/streaming/ReceiverSuite.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/3316a9d7/streaming/src/test/scala/org/apache/spark/streaming/ReceiverSuite.scala ---------------------------------------------------------------------- diff --git a/streaming/src/test/scala/org/apache/spark/streaming/ReceiverSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/ReceiverSuite.scala index 145c48e..fc6218a 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/ReceiverSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/ReceiverSuite.scala @@ -105,13 +105,13 @@ class ReceiverSuite extends TestSuiteBase with TimeLimits with Serializable { assert(executor.errors.head.eq(exception)) // Verify restarting actually stops and starts the receiver - receiver.restart("restarting", null, 100) - eventually(timeout(50 millis), interval(10 millis)) { + receiver.restart("restarting", null, 600) + eventually(timeout(300 millis), interval(10 millis)) { // receiver will be stopped async assert(receiver.isStopped) assert(receiver.onStopCalled) } - eventually(timeout(1000 millis), interval(100 millis)) { + eventually(timeout(1000 millis), interval(10 millis)) { // receiver will be started async assert(receiver.onStartCalled) assert(executor.isReceiverStarted) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
