diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2014-01-04 08:39:00 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2014-01-04 08:39:00 -0800 |
| commit | 3d4474330d9cd7d7c1b1e9fc1f8678bc6ee905e9 (patch) | |
| tree | 9f746f2583ee3f2136b991cf8ce086b911f416af | |
| parent | a1b8dd53e3474dae2c49b30bc9719c7f6b98c7cc (diff) | |
| download | spark-3d4474330d9cd7d7c1b1e9fc1f8678bc6ee905e9.tar.gz spark-3d4474330d9cd7d7c1b1e9fc1f8678bc6ee905e9.tar.bz2 spark-3d4474330d9cd7d7c1b1e9fc1f8678bc6ee905e9.zip | |
Removed the exponential backoff for testing.
| -rw-r--r-- | core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala | 2 |
1 files changed, 1 insertions, 1 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 e8ae2d302b..7485b89cf4 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 @@ -168,7 +168,7 @@ private[spark] class DriverRunner( val exitCode = process.get.waitFor() if (supervise && exitCode != 0 && !killed) { - waitSeconds = waitSeconds * 2 // exponential back-off + waitSeconds = waitSeconds * 1 // exponential back-off logInfo(s"Command exited with status $exitCode, re-launching after $waitSeconds s.") (0 until waitSeconds).takeWhile(f => {Thread.sleep(1000); !killed}) } |