We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8f583b9 commit abab461Copy full SHA for abab461
1 file changed
streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala
@@ -694,8 +694,8 @@ class StreamingContext private[streaming] (
694
def stop(stopSparkContext: Boolean, stopGracefully: Boolean): Unit = {
695
var shutdownHookRefToRemove: AnyRef = null
696
if (AsynchronousListenerBus.withinListenerThread.value) {
697
- throw new SparkException("Cannot stop StreamingContext within listener thread of
698
- AsynchronousListenerBus")
+ throw new SparkException("Cannot stop StreamingContext within listener thread of" +
+ " AsynchronousListenerBus")
699
}
700
synchronized {
701
try {
0 commit comments