From 3d4474330d9cd7d7c1b1e9fc1f8678bc6ee905e9 Mon Sep 17 00:00:00 2001 From: Tathagata Das Date: Sat, 4 Jan 2014 08:39:00 -0800 Subject: Removed the exponential backoff for testing. --- core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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}) } -- cgit v1.2.3