From 3f7e9b265cfdd6ea2cb44e677b4e20186c3ae917 Mon Sep 17 00:00:00 2001 From: Kay Ousterhout Date: Wed, 9 Oct 2013 15:23:04 -0700 Subject: Fixed comment to use javadoc style --- .../scala/org/apache/spark/scheduler/SparkListenerBus.scala | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/scheduler/SparkListenerBus.scala b/core/src/main/scala/org/apache/spark/scheduler/SparkListenerBus.scala index 8283c4b392..4d3e4a17ba 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/SparkListenerBus.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/SparkListenerBus.scala @@ -71,11 +71,11 @@ private[spark] class SparkListenerBus() extends Logging { } } - /** Waits until there are no more events in the queue, or until the specified time has elapsed. - * - * Used for testing only. Returns true if the queue has emptied and false is the specified time - * elapsed before the queue emptied. - */ + /** + * Waits until there are no more events in the queue, or until the specified time has elapsed. + * Used for testing only. Returns true if the queue has emptied and false is the specified time + * elapsed before the queue emptied. + */ def waitUntilEmpty(timeoutMillis: Int): Boolean = { val finishTime = System.currentTimeMillis + timeoutMillis while (!eventQueue.isEmpty()) { -- cgit v1.2.3