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 4b18369 commit 0069e71Copy full SHA for 0069e71
core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -1941,7 +1941,8 @@ private[spark] class DAGScheduler(
1941
hostToUnregisterOutputs: Option[String],
1942
maybeEpoch: Option[Long] = None): Unit = {
1943
val currentEpoch = maybeEpoch.getOrElse(mapOutputTracker.getEpoch)
1944
- logDebug(s"Removing executor $execId, fileLost: $fileLost, currentEpoch: $currentEpoch")
+ logDebug(s"Considering removal of executor $execId; " +
1945
+ s"fileLost: $fileLost, currentEpoch: $currentEpoch")
1946
if (!failedEpoch.contains(execId) || failedEpoch(execId) < currentEpoch) {
1947
failedEpoch(execId) = currentEpoch
1948
logInfo(s"Executor lost: $execId (epoch $currentEpoch)")
0 commit comments