Fix test failures in local mode due to updateEpoch
This commit is contained in:
parent
9159d2d09d
commit
640f253a65
|
@ -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.
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in a new issue