Skip to content

Commit 3ea1ca1

Browse files
committed
remove duplicate serialize
1 parent 743a7ad commit 3ea1ca1

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -143,8 +143,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A
143143
for (task <- tasks.flatten) {
144144
freeCores(task.executorId) -= scheduler.CPUS_PER_TASK
145145
val ser = SparkEnv.get.closureSerializer.newInstance()
146-
val taskBytes = ser.serialize(task).array()
147-
val serializedTask = ser.serialize(taskBytes)
146+
val serializedTask = ser.serialize(task)
148147
if (serializedTask.limit >= akkaFrameSize - 1024) {
149148
var msg = "Serialized task %s:%d were %d bytes which " +
150149
"exceeds spark.akka.frameSize (%d bytes)."

0 commit comments

Comments
 (0)