diff options
author | Kay Ousterhout <kayousterhout@gmail.com> | 2013-10-09 15:23:04 -0700 |
---|---|---|
committer | Kay Ousterhout <kayousterhout@gmail.com> | 2013-10-09 15:23:04 -0700 |
commit | 3f7e9b265cfdd6ea2cb44e677b4e20186c3ae917 (patch) | |
tree | 28b4eb9700f144938f5aa4bf4239923479188d12 | |
parent | a34a4e8174b5f285a327d7ff30ac9f3ff0db7689 (diff) | |
download | spark-3f7e9b265cfdd6ea2cb44e677b4e20186c3ae917.tar.gz spark-3f7e9b265cfdd6ea2cb44e677b4e20186c3ae917.tar.bz2 spark-3f7e9b265cfdd6ea2cb44e677b4e20186c3ae917.zip |
Fixed comment to use javadoc style
-rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/SparkListenerBus.scala | 10 |
1 files 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()) {
|