diff options
| author | Justin Ma <jtma@eecs.berkeley.edu> | 2010-10-07 14:41:10 -0700 |
|---|---|---|
| committer | Justin Ma <jtma@eecs.berkeley.edu> | 2010-10-07 14:41:10 -0700 |
| commit | f9671b086b8e4faba8feb6fb6fa5a61ae4290ca3 (patch) | |
| tree | 98b1b45c75798a10a427bc5134b8a4206d83cd0c /src | |
| parent | 4cbca25f4953ee89fee0b796c148dc1b0a8c3a69 (diff) | |
| download | spark-f9671b086b8e4faba8feb6fb6fa5a61ae4290ca3.tar.gz spark-f9671b086b8e4faba8feb6fb6fa5a61ae4290ca3.tar.bz2 spark-f9671b086b8e4faba8feb6fb6fa5a61ae4290ca3.zip | |
got rid of unnecessary line
Diffstat (limited to 'src')
| -rw-r--r-- | src/scala/spark/MesosScheduler.scala | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/src/scala/spark/MesosScheduler.scala b/src/scala/spark/MesosScheduler.scala index 6575b48e8b..873a97c59c 100644 --- a/src/scala/spark/MesosScheduler.scala +++ b/src/scala/spark/MesosScheduler.scala @@ -308,7 +308,6 @@ extends ParallelOperation with Logging val result = Utils.deserialize[TaskResult[T]](status.getData) results(index) = result.value // Update accumulators - print(" with " + result.accumUpdates.size + " accumulatedUpdates") Accumulators.add(callingThread, result.accumUpdates) // Mark finished and stop if we've finished all the tasks finished(index) = true |