Fixed comment to use javadoc style
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/3f7e9b26 Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/3f7e9b26 Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/3f7e9b26 Branch: refs/heads/scala-2.10 Commit: 3f7e9b265cfdd6ea2cb44e677b4e20186c3ae917 Parents: a34a4e8 Author: Kay Ousterhout <kayousterh...@gmail.com> Authored: Wed Oct 9 15:23:04 2013 -0700 Committer: Kay Ousterhout <kayousterh...@gmail.com> Committed: Wed Oct 9 15:23:04 2013 -0700 ---------------------------------------------------------------------- .../org/apache/spark/scheduler/SparkListenerBus.scala | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/3f7e9b26/core/src/main/scala/org/apache/spark/scheduler/SparkListenerBus.scala ---------------------------------------------------------------------- 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 8283c4b..4d3e4a1 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()) {
