Github user gengliangwang commented on a diff in the pull request:
https://github.com/apache/spark/pull/20955#discussion_r178681925
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/ui/AllExecutionsPage.scala
---
@@ -39,7 +39,7 @@ private[ui] class AllExecutionsPage(parent: SQLTab)
extends WebUIPage("") with L
val failed = new mutable.ArrayBuffer[SQLExecutionUIData]()
sqlStore.executionsList().foreach { e =>
- val isRunning = e.jobs.exists { case (_, status) => status ==
JobExecutionStatus.RUNNING }
+ val isRunning = e.completionTime.isEmpty
--- End diff --
Make sense. I have updated the code.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
