From 1d35c7d5417a67a509df7451adb8b4effeb3d09b Mon Sep 17 00:00:00 2001 From: witgo Date: Wed, 14 May 2014 11:20:36 +0800 Subject: [PATCH] fix hang --- .../scheduler/cluster/CoarseGrainedSchedulerBackend.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 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 index 65b2355e97da5..f1eb6e857af55 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala @@ -147,9 +147,9 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A var msg = "Serialized task %s:%d were %d bytes which " + "exceeds spark.akka.frameSize (%d bytes)." msg = msg.format(task.taskId, task.index, serializedTask.limit, akkaFrameSize) - val exception = new SparkException(msg) - logError(msg, exception) - throw exception + scheduler.error(msg) + // TODO: Need to throw an exception? + throw new SparkException(msg) } freeCores(task.executorId) -= scheduler.CPUS_PER_TASK executorActor(task.executorId) ! LaunchTask(new SerializableBuffer(serializedTask))