Minor changes as per review comments

Sital Kedia · Sital Kedia · commit be3b3dbd2d81 · 2017-03-24T15:39:05.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -1333,7 +1333,7 @@ class DAGScheduler(
               // assume all shuffle data on the node is bad.
               Some(bmAddress.host)
             } else {
-              // Deregister shuffle data just for one executor (we don't have any
+              // Unregister shuffle data just for one executor (we don't have any
               // reason to believe shuffle data has been lost for the entire host).
               None
             }
@@ -1379,10 +1379,10 @@ class DAGScheduler(
     // if the cluster manager explicitly tells us that the entire worker was lost, then
     // we know to unregister shuffle output.  (Note that "worker" specifically refers to the process
     // from a Standalone cluster, where the shuffle service lives in the Worker.)
-    val filesLost = workerLost || !env.blockManager.externalShuffleServiceEnabled
+    val fileLost = workerLost || !env.blockManager.externalShuffleServiceEnabled
     removeExecutorAndUnregisterOutputs(
       execId = execId,
-      fileLost = filesLost,
+      fileLost = fileLost,
       hostToUnregisterOutputs = None,
       maybeEpoch = None)
   }
@@ -1717,8 +1717,7 @@ private[scheduler] class DAGSchedulerEventProcessLoop(dagScheduler: DAGScheduler
 
     case ExecutorLost(execId, reason) =>
       val workerLost = reason match {
-        case SlaveLost(_, true) =>
-          true
+        case SlaveLost(_, true) => true
         case _ => false
       }
       dagScheduler.handleExecutorLost(execId, workerLost)
