ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Fixed comment to use javadoc style

Browse source
This commit is contained in:
Kay Ousterhout 2013-10-09 15:23:04 -07:00
parent a34a4e8174
commit 3f7e9b265c
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
core/src/main/scala/org/apache/spark/scheduler/SparkListenerBus.scala
View file

@ -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()) {