diff options
| author | Mark Hamstra <markhamstra@gmail.com> | 2013-08-20 00:17:16 -0700 |
|---|---|---|
| committer | Mark Hamstra <markhamstra@gmail.com> | 2013-08-20 00:17:16 -0700 |
| commit | 1630fbf838fff101e36324934a165f95fb324482 (patch) | |
| tree | cc56636c0109d06925e22162c11404fd4a8116c7 | |
| parent | ad18410427190572f90754624469a7e806c78971 (diff) | |
| download | spark-1630fbf838fff101e36324934a165f95fb324482.tar.gz spark-1630fbf838fff101e36324934a165f95fb324482.tar.bz2 spark-1630fbf838fff101e36324934a165f95fb324482.zip | |
changeGeneration --> changeEpoch renaming
| -rw-r--r-- | core/src/main/scala/spark/scheduler/DAGScheduler.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/spark/scheduler/DAGScheduler.scala index 7823d0c8cf..9402f18a0f 100644 --- a/core/src/main/scala/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/spark/scheduler/DAGScheduler.scala @@ -635,7 +635,7 @@ class DAGScheduler( mapOutputTracker.registerMapOutputs( stage.shuffleDep.get.shuffleId, stage.outputLocs.map(list => if (list.isEmpty) null else list.head).toArray, - changeGeneration = true) + changeEpoch = true) } clearCacheLocs() if (stage.outputLocs.count(_ == Nil) != 0) { @@ -718,7 +718,7 @@ class DAGScheduler( for ((shuffleId, stage) <- shuffleToMapStage) { stage.removeOutputsOnExecutor(execId) val locs = stage.outputLocs.map(list => if (list.isEmpty) null else list.head).toArray - mapOutputTracker.registerMapOutputs(shuffleId, locs, changeGeneration = true) + mapOutputTracker.registerMapOutputs(shuffleId, locs, changeEpoch = true) } if (shuffleToMapStage.isEmpty) { mapOutputTracker.incrementEpoch() |