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 /core | |
| parent | a34a4e8174b5f285a327d7ff30ac9f3ff0db7689 (diff) | |
| download | spark-3f7e9b265cfdd6ea2cb44e677b4e20186c3ae917.tar.gz spark-3f7e9b265cfdd6ea2cb44e677b4e20186c3ae917.tar.bz2 spark-3f7e9b265cfdd6ea2cb44e677b4e20186c3ae917.zip | |
Fixed comment to use javadoc style
Diffstat (limited to 'core')
| -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()) {
|