diff --git a/src/scala/spark/MesosScheduler.scala b/src/scala/spark/MesosScheduler.scala index 6575b48e8b495485a1f9cada4da477eaa496d250..873a97c59c14436bad326ac985c746e5b1750508 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