From 640f253a6572208efa24a36a6442ac08a266cf24 Mon Sep 17 00:00:00 2001 From: Josh Rosen Date: Sun, 20 Oct 2013 14:49:05 -0700 Subject: [PATCH] Fix test failures in local mode due to updateEpoch --- core/src/main/scala/org/apache/spark/MapOutputTracker.scala | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/MapOutputTracker.scala b/core/src/main/scala/org/apache/spark/MapOutputTracker.scala index f0f8f2d2c7..43e32602e5 100644 --- a/core/src/main/scala/org/apache/spark/MapOutputTracker.scala +++ b/core/src/main/scala/org/apache/spark/MapOutputTracker.scala @@ -273,10 +273,7 @@ private[spark] class MapOutputTrackerMaster extends MapOutputTracker { } override def updateEpoch(newEpoch: Long) { - // This might be called on the MapOutputTrackerMaster if we're running in local mode: - epochLock.synchronized { - assert (newEpoch == epoch) - } + // This might be called on the MapOutputTrackerMaster if we're running in local mode. } }