Github user gengliangwang commented on a diff in the pull request:
https://github.com/apache/spark/pull/21809#discussion_r204634172
--- Diff: core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala ---
@@ -115,6 +115,8 @@ private[ui] class StagePage(parent: StagesTab, store:
AppStatusStore) extends We
return UIUtils.headerSparkPage(request, stageHeader, content,
parent)
}
+ val stageJobIds = parent.store.getJobIdsAssociatedWithStage(stageId,
stageAttemptId)
--- End diff --
E.g. we can add a function to return the whole StageDataWrapper in
AppStatusStore
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
