Was mistakenly serializing the accumulator in test suite.

apache · Jan 23, 2015 · 8d5a091 · 8d5a091
1 parent 9c6a4fa
commit 8d5a091
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/core/src/test/scala/org/apache/spark/scheduler/OutputCommitCoordinatorSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/OutputCommitCoordinatorSuite.scala
@@ -137,14 +137,10 @@ class OutputCommitCoordinatorSuite
     }
 
     @throws(classOf[IOException])
-    private def writeObject(out: ObjectOutputStream) {
-      out.writeObject(accum)
-    }
+    private def writeObject(out: ObjectOutputStream) {}
 
     @throws(classOf[IOException])
-    private def readObject(in: ObjectInputStream) {
-      accum = in.readObject.asInstanceOf[Accumulator[Int]]
-    }
+    private def readObject(in: ObjectInputStream) {}
   }
 
   /**