Skip to content

Commit ebd72f4

Browse files
committed
[SPARK-20843][CORE] Add a config to set driver terminate timeout
## What changes were proposed in this pull request? Add a `worker` configuration to set how long to wait before forcibly killing driver. ## How was this patch tested? Jenkins Author: Shixiong Zhu <[email protected]> Closes #18126 from zsxwing/SPARK-20843. (cherry picked from commit 6c1dbd6) Signed-off-by: Shixiong Zhu <[email protected]>
1 parent 6e6adcc commit ebd72f4

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,8 @@ private[deploy] class DriverRunner(
5757
@volatile private[worker] var finalException: Option[Exception] = None
5858

5959
// Timeout to wait for when trying to terminate a driver.
60-
private val DRIVER_TERMINATE_TIMEOUT_MS = 10 * 1000
60+
private val DRIVER_TERMINATE_TIMEOUT_MS =
61+
conf.getTimeAsMs("spark.worker.driverTerminateTimeout", "10s")
6162

6263
// Decoupled for testing
6364
def setClock(_clock: Clock): Unit = {

0 commit comments

Comments
 (0)