fix Statement order

witgo · witgo · commit 79655800d19f · 2014-05-14T10:27:24.000+08:00
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
@@ -141,7 +141,6 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A
     // Launch tasks returned by a set of resource offers
     def launchTasks(tasks: Seq[Seq[TaskDescription]]) {
       for (task <- tasks.flatten) {
-        freeCores(task.executorId) -= scheduler.CPUS_PER_TASK
         val ser = SparkEnv.get.closureSerializer.newInstance()
         val serializedTask = ser.serialize(task)
         if (serializedTask.limit >= akkaFrameSize - 1024) {
@@ -152,6 +151,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A
           logError(msg, exception)
           throw exception
         }
+        freeCores(task.executorId) -= scheduler.CPUS_PER_TASK
         executorActor(task.executorId) ! LaunchTask(new SerializableBuffer(serializedTask))
       }
     }

Original file line number	Diff line number	Diff line change
`@@ -141,7 +141,6 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A`
`141`	`141`	`// Launch tasks returned by a set of resource offers`
`142`	`142`	`def launchTasks(tasks: Seq[Seq[TaskDescription]]) {`
`143`	`143`	`for (task <- tasks.flatten) {`
`144`		`- freeCores(task.executorId) -= scheduler.CPUS_PER_TASK`
`145`	`144`	`val ser = SparkEnv.get.closureSerializer.newInstance()`
`146`	`145`	`val serializedTask = ser.serialize(task)`
`147`	`146`	`if (serializedTask.limit >= akkaFrameSize - 1024) {`
`@@ -152,6 +151,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A`
`152`	`151`	`logError(msg, exception)`
`153`	`152`	`throw exception`
`154`	`153`	`}`
	`154`	`+ freeCores(task.executorId) -= scheduler.CPUS_PER_TASK`
`155`	`155`	`executorActor(task.executorId) ! LaunchTask(new SerializableBuffer(serializedTask))`
`156`	`156`	`}`
`157`	`157`	`}`