Skip to content

Commit ced71d3

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 86bf93e commit ced71d3

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -481,9 +481,10 @@ private[spark] class Executor(
481481
} catch {
482482
case NonFatal(e) =>
483483
logWarning("Issue communicating with driver in heartbeater", e)
484-
logError(s"Unable to send heartbeats to driver more than $HEARTBEAT_MAX_FAILURES times")
485484
heartbeatFailures += 1
486485
if (heartbeatFailures >= HEARTBEAT_MAX_FAILURES) {
486+
logError(s"Exit as unable to send heartbeats to driver " +
487+
s"more than $HEARTBEAT_MAX_FAILURES times")
487488
System.exit(ExecutorExitCode.HEARTBEAT_FAILURE)
488489
}
489490
}

0 commit comments

Comments
 (0)