[GitHub] [spark] Ngone51 commented on a diff in pull request #37411: [SPARK-39984][CORE] Check workerLastHeartbeat with master before HeartbeatReceiver expires an executor

Ngone51 commented on code in PR #37411: URL: https://github.com/apache/spark/pull/37411#discussion_r960664710 ## core/src/main/scala/org/apache/spark/internal/config/package.scala: ## @@ -2422,4 +2422,24 @@ package object config { .version("3.4.0")

[GitHub] [spark] Ngone51 commented on a diff in pull request #37411: [SPARK-39984][CORE] Check workerLastHeartbeat with master before HeartbeatReceiver expires an executor

Ngone51 commented on code in PR #37411: URL: https://github.com/apache/spark/pull/37411#discussion_r960646158 ## core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala: ## @@ -77,17 +77,61 @@ private[spark] class HeartbeatReceiver(sc: SparkContext, clock: Clock)

[GitHub] [spark] Ngone51 commented on a diff in pull request #37411: [SPARK-39984][CORE] Check workerLastHeartbeat with master before HeartbeatReceiver expires an executor

Ngone51 commented on code in PR #37411: URL: https://github.com/apache/spark/pull/37411#discussion_r953806281 ## core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala: ## @@ -77,17 +77,61 @@ private[spark] class HeartbeatReceiver(sc: SparkContext, clock: Clock)

[GitHub] [spark] Ngone51 commented on a diff in pull request #37411: [SPARK-39984][CORE] Check workerLastHeartbeat with master before HeartbeatReceiver expires an executor

Ngone51 commented on code in PR #37411: URL: https://github.com/apache/spark/pull/37411#discussion_r953806461 ## core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala: ## @@ -77,17 +77,61 @@ private[spark] class HeartbeatReceiver(sc: SparkContext, clock: Clock)

[GitHub] [spark] Ngone51 commented on a diff in pull request #37411: [SPARK-39984][CORE] Check workerLastHeartbeat with master before HeartbeatReceiver expires an executor

Ngone51 commented on code in PR #37411: URL: https://github.com/apache/spark/pull/37411#discussion_r953803448 ## core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala: ## @@ -77,17 +77,61 @@ private[spark] class HeartbeatReceiver(sc: SparkContext, clock: Clock)

[GitHub] [spark] Ngone51 commented on a diff in pull request #37411: [SPARK-39984][CORE] Check workerLastHeartbeat with master before HeartbeatReceiver expires an executor

Ngone51 commented on code in PR #37411: URL: https://github.com/apache/spark/pull/37411#discussion_r953765470 ## core/src/main/scala/org/apache/spark/internal/config/package.scala: ## @@ -2398,4 +2398,20 @@ package object config { .version("3.3.0") .intConf

[GitHub] [spark] Ngone51 commented on a diff in pull request #37411: [SPARK-39984][CORE] Check workerLastHeartbeat with master before HeartbeatReceiver expires an executor

Ngone51 commented on code in PR #37411: URL: https://github.com/apache/spark/pull/37411#discussion_r945376133 ## core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala: ## @@ -199,41 +241,120 @@ private[spark] class HeartbeatReceiver(sc: SparkContext, clock: Clock)

[GitHub] [spark] Ngone51 commented on a diff in pull request #37411: [SPARK-39984][CORE] Check workerLastHeartbeat with master before HeartbeatReceiver expires an executor

Ngone51 commented on code in PR #37411: URL: https://github.com/apache/spark/pull/37411#discussion_r945367796 ## core/src/main/scala/org/apache/spark/internal/config/Network.scala: ## @@ -51,6 +51,21 @@ private[spark] object Network { .timeConf(TimeUnit.MILLISECONDS)

[GitHub] [spark] Ngone51 commented on a diff in pull request #37411: [SPARK-39984][CORE] Check workerLastHeartbeat with master before HeartbeatReceiver expires an executor

Ngone51 commented on code in PR #37411: URL: https://github.com/apache/spark/pull/37411#discussion_r945367796 ## core/src/main/scala/org/apache/spark/internal/config/Network.scala: ## @@ -51,6 +51,21 @@ private[spark] object Network { .timeConf(TimeUnit.MILLISECONDS)