From a2aa7ab2578bc3ff2064e25d4026a9c9fbd87bb9 Mon Sep 17 00:00:00 2001 From: John Lee Date: Fri, 14 Jul 2017 09:14:29 -0500 Subject: [PATCH] comment reverted since the code has been --- .../main/scala/org/apache/spark/scheduler/LiveListenerBus.scala | 2 +- 1 file changed, 1 insertion(+), 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 index 25318001fdbb1..5accd2ad57695 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala @@ -200,7 +200,7 @@ private[spark] class LiveListenerBus(conf: SparkConf) extends SparkListenerBus { private def queueIsEmpty: Boolean = synchronized { eventQueue.isEmpty && !processingEvent } /** - * Stop the listener bus. It will clear the queued events for faster shutdown and drop the + * Stop the listener bus. It will wait until the queued events have been processed, but drop the * new events after stopping. */ def stop(): Unit = {