Always fallback to destroy()

apache · Dec 31, 2015 · 9ed4377 · 9ed4377
1 parent 67611ac
commit 9ed4377
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/util/Utils.scala b/core/src/main/scala/org/apache/spark/util/Utils.scala
@@ -1722,9 +1722,8 @@ private[spark] object Utils extends Logging {
       case NonFatal(e) =>
         if (!e.isInstanceOf[NoSuchMethodException]) {
           logWarning("Exception when attempting to kill process", e)
-        } else {
-          process.destroy()
         }
+        process.destroy()
     }
     if (waitForProcess(process, timeoutMs)) {
       Option(process.exitValue())