Permalink
Browse files

code clean

  • Loading branch information...
1 parent ef2d43f commit 6a4e3a30f6029027e1f4f9594307047c7c0e564b @CodingCat CodingCat committed Mar 1, 2014
Showing with 1 addition and 1 deletion.
  1. +1 −1 core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala
@@ -643,7 +643,7 @@ class PairRDDFunctions[K: ClassTag, V: ClassTag](self: RDD[(K, V)])
val jobTaskContext = newTaskAttemptContext(wrappedConf.value, jobAttemptId)
val jobCommitter = jobFormat.getOutputCommitter(jobTaskContext)
jobCommitter.setupJob(jobTaskContext)
- self.context.runJob(self, writeShard _).sum
+ self.context.runJob(self, writeShard _)
jobCommitter.commitJob(jobTaskContext)
}

0 comments on commit 6a4e3a3

Please sign in to comment.