Github user devaraj-kavali commented on a diff in the pull request:
https://github.com/apache/spark/pull/22625#discussion_r222786641
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala
---
@@ -98,6 +98,8 @@ class CoarseGrainedSchedulerBackend(scheduler:
TaskSchedulerImpl, val rpcEnv: Rp
private val reviveThread =
ThreadUtils.newDaemonSingleThreadScheduledExecutor("driver-revive-thread")
+ private var driverEndpointStopped = false
--- End diff --
If we keep the `driverEndpointStopped` inside `DriverEndpoint`, need to
have another var for `DriverEndpoint` ref from
`rpcEnv.setupEndpoint(ENDPOINT_NAME, createDriverEndpoint(properties))` to
access the `DriverEndpoint.driverEndpointStopped`.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
