Skip to content

Commit e9a2f5a

Browse files
colinmjjGitHub Enterprise
authored andcommitted
[MINOR] Add debug info to check the task num in executor (apache#506)
1 parent b7d9898 commit e9a2f5a

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,8 @@ private[spark] class CoarseGrainedExecutorBackend(
190190
exitExecutor(1, "Received LaunchTask command but executor was null")
191191
} else {
192192
val taskDesc = TaskDescription.decode(data.value)
193-
logInfo("Got assigned task " + taskDesc.taskId)
193+
logInfo(s"Got assigned task ${taskDesc.taskId}, " +
194+
s"current executor running ${executor.runningTasks.size} tasks")
194195
taskResources.put(taskDesc.taskId, taskDesc.resources)
195196
executor.launchTask(this, taskDesc)
196197
}

0 commit comments

Comments
 (0)