This is an automated email from the ASF dual-hosted git repository.
dongjoon pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new 73f9f5296e3 [SPARK-45500][CORE][WEBUI][FOLLOWUP] Show `RELAUNCHING`
drivers too
73f9f5296e3 is described below
commit 73f9f5296e36541db78ab10c4c01a56fbc17cca8
Author: Dongjoon Hyun <dh...@apple.com>
AuthorDate: Tue Oct 17 21:56:30 2023 -0700
[SPARK-45500][CORE][WEBUI][FOLLOWUP] Show `RELAUNCHING` drivers too
### What changes were proposed in this pull request?
This is a follow-up of #43328 to show `RELAUNCHING` drivers too.
### Why are the changes needed?
When we submit with `--supervise` option, the abnormally-completed driver
is in `RELAUNCHING` status and newly launched driver is in `SUBMITTED` status.
https://github.com/apache/spark/blob/0cb4a84f6ab0c1bd101e6bc72be82987bbc02e9b/core/src/main/scala/org/apache/spark/deploy/master/Master.scala#L995
### Does this PR introduce _any_ user-facing change?
Yes, but this is a new UI item.
### How was this patch tested?
Manual tests.
### Was this patch authored or co-authored using generative AI tooling?
No.
Closes #43418 from dongjoon-hyun/SPARK-45500-2.
Authored-by: Dongjoon Hyun <dh...@apple.com>
Signed-off-by: Dongjoon Hyun <dh...@apple.com>
---
core/src/main/scala/org/apache/spark/deploy/master/ui/MasterPage.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/core/src/main/scala/org/apache/spark/deploy/master/ui/MasterPage.scala
b/core/src/main/scala/org/apache/spark/deploy/master/ui/MasterPage.scala
index 5c1887be5b8..48c0c9601c1 100644
--- a/core/src/main/scala/org/apache/spark/deploy/master/ui/MasterPage.scala
+++ b/core/src/main/scala/org/apache/spark/deploy/master/ui/MasterPage.scala
@@ -156,7 +156,8 @@ private[ui] class MasterPage(parent: MasterWebUI) extends
WebUIPage("") {
{state.completedDrivers.length} Completed
({state.completedDrivers.count(_.state == DriverState.KILLED)}
Killed,
{state.completedDrivers.count(_.state == DriverState.FAILED)}
Failed,
- {state.completedDrivers.count(_.state == DriverState.ERROR)}
Error)
+ {state.completedDrivers.count(_.state == DriverState.ERROR)}
Error,
+ {state.completedDrivers.count(_.state ==
DriverState.RELAUNCHING)} Relaunching)
</li>
<li><strong>Status:</strong> {state.status}</li>
</ul>
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
