remove duplicate serialize

xiliu82 · May 12, 2014 · 3ea1ca1 · 3ea1ca1
1 parent 743a7ad
commit 3ea1ca1
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala b/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala
@@ -143,8 +143,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A
       for (task <- tasks.flatten) {
         freeCores(task.executorId) -= scheduler.CPUS_PER_TASK
         val ser = SparkEnv.get.closureSerializer.newInstance()
-        val taskBytes = ser.serialize(task).array()
-        val serializedTask = ser.serialize(taskBytes)
+        val serializedTask = ser.serialize(task)
         if (serializedTask.limit >= akkaFrameSize - 1024) {
           var msg = "Serialized task %s:%d were %d bytes which " +
             "exceeds spark.akka.frameSize (%d bytes)."