Skip to content

Commit 644dbb6

Browse files
zsxwingAndrew Or
authored andcommitted
[SPARK-13522][CORE] Fix the exit log place for heartbeat
## What changes were proposed in this pull request? Just fixed the log place introduced by #11401 ## How was this patch tested? unit tests. Author: Shixiong Zhu <[email protected]> Closes #11432 from zsxwing/SPARK-13522-follow-up.
1 parent 17a253c commit 644dbb6

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

core/src/main/scala/org/apache/spark/executor/Executor.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -478,9 +478,10 @@ private[spark] class Executor(
478478
} catch {
479479
case NonFatal(e) =>
480480
logWarning("Issue communicating with driver in heartbeater", e)
481-
logError(s"Unable to send heartbeats to driver more than $HEARTBEAT_MAX_FAILURES times")
482481
heartbeatFailures += 1
483482
if (heartbeatFailures >= HEARTBEAT_MAX_FAILURES) {
483+
logError(s"Exit as unable to send heartbeats to driver " +
484+
s"more than $HEARTBEAT_MAX_FAILURES times")
484485
System.exit(ExecutorExitCode.HEARTBEAT_FAILURE)
485486
}
486487
}

0 commit comments

Comments
 (0)