You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ma...@apache.org on 2013/10/22 19:20:48 UTC
[3/4] git commit: Unwrap a long line that actually fits.
Unwrap a long line that actually fits.
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/1fa5baf9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/1fa5baf9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/1fa5baf9
Branch: refs/heads/master
Commit: 1fa5baf9ab3382d8fb61cdf5d755fb9d45512e26
Parents: 640f253
Author: Josh Rosen <jo...@apache.org>
Authored: Sun Oct 20 14:50:21 2013 -0700
Committer: Josh Rosen <jo...@apache.org>
Committed: Sun Oct 20 14:50:21 2013 -0700
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/MapOutputTracker.scala | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/1fa5baf9/core/src/main/scala/org/apache/spark/MapOutputTracker.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/MapOutputTracker.scala b/core/src/main/scala/org/apache/spark/MapOutputTracker.scala
index 43e3260..5e465fa 100644
--- a/core/src/main/scala/org/apache/spark/MapOutputTracker.scala
+++ b/core/src/main/scala/org/apache/spark/MapOutputTracker.scala
@@ -203,8 +203,7 @@ private[spark] class MapOutputTrackerMaster extends MapOutputTracker {
}
}
- def registerMapOutputs(shuffleId: Int, statuses: Array[MapStatus],
- changeEpoch: Boolean = false) {
+ def registerMapOutputs(shuffleId: Int, statuses: Array[MapStatus], changeEpoch: Boolean = false) {
mapStatuses.put(shuffleId, Array[MapStatus]() ++ statuses)
if (changeEpoch) {
incrementEpoch()