Got rid of terrible double-negative name

xiliu82 · Jun 25, 2014 · 42dfa7e · 42dfa7e
1 parent 80b3205
commit 42dfa7e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -1038,7 +1038,7 @@ class DAGScheduler(
   private def failJobAndIndependentStages(job: ActiveJob, failureReason: String,
       resultStage: Option[Stage]) {
     val error = new SparkException(failureReason)
-    var unableToCancelStages = false
+    var ableToCancelStages = true
 
     val shouldInterruptThread =
       if (job.properties == null) false
@@ -1070,14 +1070,14 @@ class DAGScheduler(
             } catch {
               case e: UnsupportedOperationException =>
                 logInfo(s"Could not cancel tasks for stage $stageId", e)
-              unableToCancelStages = true
+              ableToCancelStages = false
             }
           }
         }
       }
     }
 
-    if (!unableToCancelStages) {
+    if (ableToCancelStages) {
       job.listener.jobFailed(error)
       cleanupStateForJobAndIndependentStages(job, resultStage)
       listenerBus.post(SparkListenerJobEnd(job.jobId, JobFailed(error)))