diff options
| -rw-r--r-- | core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala b/core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala index 51baa35018..e8ae2d302b 100644 --- a/core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala +++ b/core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala @@ -167,12 +167,13 @@ private[spark] class DriverRunner( val exitCode = process.get.waitFor() - keepTrying = supervise && exitCode != 0 && !killed - if (keepTrying) { + if (supervise && exitCode != 0 && !killed) { waitSeconds = waitSeconds * 2 // exponential back-off logInfo(s"Command exited with status $exitCode, re-launching after $waitSeconds s.") (0 until waitSeconds).takeWhile(f => {Thread.sleep(1000); !killed}) } + + keepTrying = supervise && exitCode != 0 && !killed } } } |