diff options
| author | Henry Saputra <hsaputra@apache.org> | 2014-01-08 00:38:29 -0800 |
|---|---|---|
| committer | Henry Saputra <hsaputra@apache.org> | 2014-01-08 00:38:29 -0800 |
| commit | aa56585d2148b3ced506d2fff89da0858300928c (patch) | |
| tree | 8451ab7f9584c81ccfd7167e184deb6db39faf53 | |
| parent | f6b6f88367351f99d02a7de0dbd5c1980cc97bbf (diff) | |
| download | spark-aa56585d2148b3ced506d2fff89da0858300928c.tar.gz spark-aa56585d2148b3ced506d2fff89da0858300928c.tar.bz2 spark-aa56585d2148b3ced506d2fff89da0858300928c.zip | |
Resolve PR review over 100 chars
| -rw-r--r-- | core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala b/core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala index c8446fd0fc..4fe3bc552b 100644 --- a/core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala +++ b/core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala @@ -613,7 +613,8 @@ class PairRDDFunctions[K: ClassTag, V: ClassTag](self: RDD[(K, V)]) // around by taking a mod. We expect that no task will be attempted 2 billion times. val attemptNumber = (context.attemptId % Int.MaxValue).toInt /* "reduce task" <split #> <attempt # = spark task #> */ - val attemptId = newTaskAttemptID(jobtrackerID, stageId, isMap = false, context.partitionId, attemptNumber) + val attemptId = newTaskAttemptID(jobtrackerID, stageId, isMap = false, context.partitionId, + attemptNumber) val hadoopContext = newTaskAttemptContext(wrappedConf.value, attemptId) val format = outputFormatClass.newInstance val committer = format.getOutputCommitter(hadoopContext) |