We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e0c6163 commit 8ff4c61Copy full SHA for 8ff4c61
streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala
@@ -344,7 +344,7 @@ class FailureReasonsCollector extends StreamingListener {
344
* A StreamingListener that calls StreamingContext.stop().
345
*/
346
class StreamingContextStoppingCollector(val ssc: StreamingContext) extends StreamingListener {
347
- var sparkExSeen = false
+ volatile var sparkExSeen = false
348
override def onBatchCompleted(batchCompleted: StreamingListenerBatchCompleted) {
349
try {
350
ssc.stop()
0 commit comments