review commit

witgo · witgo · commit 0f524833ead0 · 2014-05-17T10:32:17.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
@@ -156,9 +156,6 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A
               case e: Exception => logError("Exception in error callback", e)
             }
           }
-          // scheduler.error(msg)
-          // TODO: Need to throw an exception?
-          // throw new SparkException(msg)
         }
         else {
           freeCores(task.executorId) -= scheduler.CPUS_PER_TASK

Original file line number	Diff line number	Diff line change
`@@ -156,9 +156,6 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A`
`156`	`156`	`case e: Exception => logError("Exception in error callback", e)`
`157`	`157`	`}`
`158`	`158`	`}`
`159`		`- // scheduler.error(msg)`
`160`		`- // TODO: Need to throw an exception?`
`161`		`- // throw new SparkException(msg)`
`162`	`159`	`}`
`163`	`160`	`else {`
`164`	`161`	`freeCores(task.executorId) -= scheduler.CPUS_PER_TASK`