removing the unused variable in PairRddFunctions.scala

apache · Oct 17, 2014 · a874047 · a874047
1 parent 3bf43c7
commit a874047
Showing 1 changed file with 0 additions and 3 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
@@ -1031,17 +1031,14 @@ class PairRDDFunctions[K, V](self: RDD[(K, V)])
 
       writer.setup(context.getStageId, context.getPartitionId, attemptNumber)
       writer.open()
-      var count = 0
       try {
         while (iter.hasNext) {
           val record = iter.next()
-          count += 1
           writer.write(record._1.asInstanceOf[AnyRef], record._2.asInstanceOf[AnyRef])
         }
       } finally {
         writer.close()
       }
-      logInfo(s"$count records are written")
       writer.commit()
     }