This is an automated email from the ASF dual-hosted git repository.
uros-b pushed a commit to branch branch-4.x
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/branch-4.x by this push:
new e37f192907f6 [SPARK-58976][UI] Remove unused
generateOutputOperationStatusForUI in BatchPage
e37f192907f6 is described below
commit e37f192907f6998ea8b20327adfcb2a7929dfb78
Author: Uros <[email protected]>
AuthorDate: Tue Aug 25 13:21:34 2026 +0000
[SPARK-58976][UI] Remove unused generateOutputOperationStatusForUI in
BatchPage
### What changes were proposed in this pull request?
This removes the unused private method
`generateOutputOperationStatusForUI(failure: String)` from the Spark Streaming
(DStreams) Web UI page `BatchPage`.
### Why are the changes needed?
The method has no callers -- its only occurrence in the codebase is its own
definition. The live code path renders output-operation failures via
`UIUtils.createOutputOperationFailureForUI` instead. Removing the dead method
reduces confusion and maintenance surface.
### Does this PR introduce _any_ user-facing change?
No. The method was never invoked, so removing it does not change any
rendered output.
### How was this patch tested?
Existing tests. This is a pure removal of an unreferenced private method; a
repo-wide search confirms `generateOutputOperationStatusForUI` had no other
references.
### Was this patch authored or co-authored using generative AI tooling?
Generated-by: Claude Code (Opus 4.8)
Closes #58252 from uros-b/batchpage-remove-dead-status.
Authored-by: Uros <[email protected]>
Signed-off-by: Uros Bojanic <[email protected]>
(cherry picked from commit 0d2137537059cb41f28b66e3042448611a8d8174)
Signed-off-by: Uros Bojanic <[email protected]>
---
.../scala/org/apache/spark/streaming/ui/BatchPage.scala | 13 -------------
1 file changed, 13 deletions(-)
diff --git
a/streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala
b/streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala
index a47b08c7b949..1fd7f5ac624c 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala
+++ b/streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala
@@ -270,19 +270,6 @@ private[ui] class BatchPage(parent: StreamingTab) extends
WebUIPage("batch") {
}
}
- private def generateOutputOperationStatusForUI(failure: String): String = {
- if (failure.startsWith("org.apache.spark.SparkException")) {
- "Failed due to Spark job error\n" + failure
- } else {
- var nextLineIndex = failure.indexOf("\n")
- if (nextLineIndex < 0) {
- nextLineIndex = failure.length
- }
- val firstLine = failure.substring(0, nextLineIndex)
- s"Failed due to error: $firstLine\n$failure"
- }
- }
-
/**
* Generate the job table for the batch.
*/
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
