You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by td...@apache.org on 2018/01/24 00:24:23 UTC
spark git commit: [SPARK-23197][DSTREAMS] Increased timeouts to
resolve flakiness
Repository: spark
Updated Branches:
refs/heads/master 44cc4daf3 -> 15adcc827
[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 <ta...@gmail.com>
Closes #20371 from tdas/SPARK-23197.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/15adcc82
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/15adcc82
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/15adcc82
Branch: refs/heads/master
Commit: 15adcc8273e73352e5e1c3fc9915c0b004ec4836
Parents: 44cc4da
Author: Tathagata Das <ta...@gmail.com>
Authored: Tue Jan 23 16:24:20 2018 -0800
Committer: Tathagata Das <ta...@gmail.com>
Committed: Tue Jan 23 16:24:20 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/15adcc82/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-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org