Fix a comment after changes.

Marcelo Vanzin · Marcelo Vanzin · commit ad6ff49de17c · 2017-09-13T10:13:09.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala b/core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala
@@ -106,7 +106,7 @@ private[spark] class LiveListenerBus(conf: SparkConf) {
       }
   }
 
-  /** An alias for postToAll(), to avoid changing all call sites. */
+  /** Post an event to all queues. */
   def post(event: SparkListenerEvent): Unit = {
     if (!stopped.get()) {
       metrics.numEventsPosted.inc()
@@ -166,6 +166,7 @@ private[spark] class LiveListenerBus(conf: SparkConf) {
 
     synchronized {
       queues.asScala.foreach(_.stop())
+      queues.clear()
     }
   }
 

Original file line number	Diff line number	Diff line change
`@@ -106,7 +106,7 @@ private[spark] class LiveListenerBus(conf: SparkConf) {`
`106`	`106`	`}`
`107`	`107`	`}`
`108`	`108`
`109`		`- /** An alias for postToAll(), to avoid changing all call sites. */`
	`109`	`+ /** Post an event to all queues. */`
`110`	`110`	`def post(event: SparkListenerEvent): Unit = {`
`111`	`111`	`if (!stopped.get()) {`
`112`	`112`	`metrics.numEventsPosted.inc()`
`@@ -166,6 +166,7 @@ private[spark] class LiveListenerBus(conf: SparkConf) {`
`166`	`166`
`167`	`167`	`synchronized {`
`168`	`168`	`queues.asScala.foreach(_.stop())`
	`169`	`+ queues.clear()`
`169`	`170`	`}`
`170`	`171`	`}`
`171`	`172`