Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21567#discussion_r196431492
--- Diff:
core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala ---
@@ -58,7 +59,7 @@ private[deploy] class DriverRunner(
// Timeout to wait for when trying to terminate a driver.
private val DRIVER_TERMINATE_TIMEOUT_MS =
- conf.getTimeAsMs("spark.worker.driverTerminateTimeout", "10s")
+ conf.getTimeAsSeconds("spark.worker.driverTerminateTimeout",
"10s").seconds.toMillis
--- End diff --
ditto
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
