Skip to content

Commit 15adcc8

Browse files
committed
[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 <[email protected]> Closes #20371 from tdas/SPARK-23197.
1 parent 44cc4da commit 15adcc8

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

streaming/src/test/scala/org/apache/spark/streaming/ReceiverSuite.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -105,13 +105,13 @@ class ReceiverSuite extends TestSuiteBase with TimeLimits with Serializable {
105105
assert(executor.errors.head.eq(exception))
106106

107107
// Verify restarting actually stops and starts the receiver
108-
receiver.restart("restarting", null, 100)
109-
eventually(timeout(50 millis), interval(10 millis)) {
108+
receiver.restart("restarting", null, 600)
109+
eventually(timeout(300 millis), interval(10 millis)) {
110110
// receiver will be stopped async
111111
assert(receiver.isStopped)
112112
assert(receiver.onStopCalled)
113113
}
114-
eventually(timeout(1000 millis), interval(100 millis)) {
114+
eventually(timeout(1000 millis), interval(10 millis)) {
115115
// receiver will be started async
116116
assert(receiver.onStartCalled)
117117
assert(executor.isReceiverStarted)

0 commit comments

Comments
 (0)