Remove return and add a space.

shenh062326 · shenh062326 · commit fbe31eb63fa3 · 2016-08-15T10:06:21.000+08:00
diff --git a/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala b/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala
@@ -800,17 +800,16 @@ private[spark] class TaskSetManager(
     maybeFinishTaskSet()
 
     // kill running task if stage failed
-    if(reason.isInstanceOf[FetchFailed]) {
+    if (reason.isInstanceOf[FetchFailed]) {
       killTasks(runningTasksSet, taskInfos)
     }
   }
 
-  def killTasks(tasks: HashSet[Long], taskInfo: HashMap[Long, TaskInfo]): Boolean = {
+  def killTasks(tasks: HashSet[Long], taskInfo: HashMap[Long, TaskInfo]): Unit = {
     tasks.foreach { task =>
       val executorId = taskInfo(task).executorId
       sched.sc.schedulerBackend.killTask(task, executorId, true)
     }
-    true
   }
 
   def abort(message: String, exception: Option[Throwable] = None): Unit = sched.synchronized {

Original file line number	Diff line number	Diff line change
`@@ -800,17 +800,16 @@ private[spark] class TaskSetManager(`
`800`	`800`	`maybeFinishTaskSet()`
`801`	`801`
`802`	`802`	`// kill running task if stage failed`
`803`		`- if(reason.isInstanceOf[FetchFailed]) {`
	`803`	`+ if (reason.isInstanceOf[FetchFailed]) {`
`804`	`804`	`killTasks(runningTasksSet, taskInfos)`
`805`	`805`	`}`
`806`	`806`	`}`
`807`	`807`
`808`		`- def killTasks(tasks: HashSet[Long], taskInfo: HashMap[Long, TaskInfo]): Boolean = {`
	`808`	`+ def killTasks(tasks: HashSet[Long], taskInfo: HashMap[Long, TaskInfo]): Unit = {`
`809`	`809`	`tasks.foreach { task =>`
`810`	`810`	`val executorId = taskInfo(task).executorId`
`811`	`811`	`sched.sc.schedulerBackend.killTask(task, executorId, true)`
`812`	`812`	`}`
`813`		`- true`
`814`	`813`	`}`
`815`	`814`
`816`	`815`	`def abort(message: String, exception: Option[Throwable] = None): Unit = sched.synchronized {`