From 3d4474330d9cd7d7c1b1e9fc1f8678bc6ee905e9 Mon Sep 17 00:00:00 2001
From: Tathagata Das <tathagata.das1565@gmail.com>
Date: Sat, 4 Jan 2014 08:39:00 -0800
Subject: [PATCH] Removed the exponential backoff for testing.
---
.../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})
}
--
GitLab