Github user jerryshao commented on a diff in the pull request:
https://github.com/apache/spark/pull/20315#discussion_r162338495
--- Diff: core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala ---
@@ -676,7 +676,7 @@ private[ui] class TaskDataSource(
private var _tasksToShow: Seq[TaskData] = null
- override def dataSize: Int = stage.numCompleteTasks +
stage.numFailedTasks + stage.numKilledTasks
--- End diff --
@vanzin I think you made this change, why not also track the running tasks?
I'm not sure what is your original purpose.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
