We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d7c250d commit dd202c7Copy full SHA for dd202c7
core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala
@@ -78,7 +78,7 @@ private[spark] class HeartbeatReceiver(sc: SparkContext)
78
case RegisterTaskScheduler(scheduler) =>
79
this.scheduler = scheduler
80
case heartbeat @ Heartbeat(executorId, taskMetrics, blockManagerId) =>
81
- if (scheduler == null) {
+ if (scheduler != null) {
82
val unknownExecutor = !scheduler.executorHeartbeatReceived(
83
executorId, taskMetrics, blockManagerId)
84
val response = HeartbeatResponse(reregisterBlockManager = unknownExecutor)
0 commit comments