Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20371#discussion_r163415477
--- Diff:
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)
--- End diff --
yeah. lets fix one at a time.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
