review commit

witgo · witgo · commit b0930b045cc5 · 2014-05-14T16:07:00.000+08:00
diff --git a/core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala b/core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala
@@ -68,7 +68,7 @@ private[spark] class CoarseGrainedExecutorBackend(
         System.exit(1)
       } else {
         val ser = SparkEnv.get.closureSerializer.newInstance()
-        val taskDesc =ser.deserialize[TaskDescription](data.value)
+        val taskDesc = ser.deserialize[TaskDescription](data.value)
         logInfo("Got assigned task " + taskDesc.taskId)
         executor.launchTask(this, taskDesc.taskId, taskDesc.serializedTask)
       }

Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,7 @@ private[spark] class CoarseGrainedExecutorBackend(`
`68`	`68`	`System.exit(1)`
`69`	`69`	`} else {`
`70`	`70`	`val ser = SparkEnv.get.closureSerializer.newInstance()`
`71`		`- val taskDesc =ser.deserialize[TaskDescription](data.value)`
	`71`	`+ val taskDesc = ser.deserialize[TaskDescription](data.value)`
`72`	`72`	`logInfo("Got assigned task " + taskDesc.taskId)`
`73`	`73`	`executor.launchTask(this, taskDesc.taskId, taskDesc.serializedTask)`
`74`	`74`	`}`