From 158b2dc3d61348cbdb53506ca1e59922e8d99048 Mon Sep 17 00:00:00 2001
From: witgo <witgo@qq.com>
Date: Wed, 14 May 2014 11:51:25 +0800
Subject: [PATCH] review commit

---
 .../scheduler/cluster/CoarseGrainedSchedulerBackend.scala   | 6 ++++--
 1 file changed, 4 insertions(+), 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
index 72d161dc86495..3cb3ca94ab761 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
@@ -152,8 +152,10 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A
           // TODO: Need to throw an exception?
           // throw new SparkException(msg)
         }
-        freeCores(task.executorId) -= scheduler.CPUS_PER_TASK
-        executorActor(task.executorId) ! LaunchTask(new SerializableBuffer(serializedTask))
+        else {
+          freeCores(task.executorId) -= scheduler.CPUS_PER_TASK
+          executorActor(task.executorId) ! LaunchTask(new SerializableBuffer(serializedTask))
+        }
       }
     }