Description
Sometimes the receiver will be registered into tracker after ssc.stop is called. Especially when stop() is called immediately after start(). So the receiver doesn't get the StopReceiver message from the tracker. In this case, when you call stop() in graceful mode, stop() would get stuck indefinitely.
Attachments
Issue Links
- is duplicated by
-
SPARK-7346 Fix a bug that ssc.stop(true, stopGracefully = true) may block forever
- Resolved
-
SPARK-5615 Fix testPackage in StreamingContextSuite
- Resolved
- links to