aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatei Zaharia <matei@eecs.berkeley.edu>2013-02-02 23:34:47 -0800
committerMatei Zaharia <matei@eecs.berkeley.edu>2013-02-02 23:34:47 -0800
commit9163c3705d98ca19c09fe5618e347b9d20f88f63 (patch)
tree0b360c2dff2a7a753da2626ec5a5d87081112b4e
parent34a7bcdb3a19deed18b25225daf47ff22ee20869 (diff)
downloadspark-9163c3705d98ca19c09fe5618e347b9d20f88f63.tar.gz
spark-9163c3705d98ca19c09fe5618e347b9d20f88f63.tar.bz2
spark-9163c3705d98ca19c09fe5618e347b9d20f88f63.zip
Formatting
-rw-r--r--core/src/main/scala/spark/scheduler/DAGScheduler.scala3
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/spark/scheduler/DAGScheduler.scala
index 2a35915560..edbfd1c45f 100644
--- a/core/src/main/scala/spark/scheduler/DAGScheduler.scala
+++ b/core/src/main/scala/spark/scheduler/DAGScheduler.scala
@@ -265,7 +265,8 @@ class DAGScheduler(
return listener.awaitResult() // Will throw an exception if the job fails
}
- /** Process one event retrieved from the event queue.
+ /**
+ * Process one event retrieved from the event queue.
* Returns true if we should stop the event loop.
*/
private[scheduler] def processEvent(event: DAGSchedulerEvent): Boolean = {