Github user caneGuy commented on a diff in the pull request:
https://github.com/apache/spark/pull/19132#discussion_r138811435
--- Diff:
core/src/main/scala/org/apache/spark/status/api/v1/AllStagesResource.scala ---
@@ -69,7 +70,8 @@ private[v1] object AllStagesResource {
}
val taskData = if (includeDetails) {
- Some(stageUiData.taskData.map { case (k, v) => k ->
convertTaskData(v) } )
+ Some(stageUiData.taskData.map { case (k, v) =>
+ k -> convertTaskData(v, stageUiData.lastUpdateTime) } )
--- End diff --
Thanks for your patient.Actually i did not check carefully.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
