Remove redundant check.

apache · Sep 18, 2017 · 77dd8ec · 77dd8ec
1 parent ed71477
commit 77dd8ec
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala b/core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala
@@ -99,7 +99,7 @@ private[spark] class LiveListenerBus(conf: SparkConf) {
       case None =>
         val newQueue = new AsyncEventQueue(queue, conf, metrics)
         newQueue.addListener(listener)
-        if (started.get() && !stopped.get()) {
+        if (started.get()) {
           newQueue.start(sparkContext)
         }
         queues.add(newQueue)