improvement_add_job_log fix

1. provide Option[Int] with JobId
davidyuan1223 · Oct 13, 2023 · 5cf8714 · 5cf8714
1 parent 249a422
commit 5cf8714
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/...ubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/SparkConsoleProgressBar.scala b/...ubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/SparkConsoleProgressBar.scala
@@ -98,8 +98,6 @@ class SparkConsoleProgressBar(
         val jobId = result.get
         jobHeader = s"[Job $jobId (${liveJobs.get(jobId).numCompleteStages} " +
           s"/ ${liveJobs.get(jobId).numStages}) Stages] "
-      } else {
-        jobHeader = s"[No job match the stage]"
       }
       val header = jobHeader + s"[Stage ${s.stageId}:"
       val tailer = s"(${s.numCompleteTasks} + ${s.numActiveTasks}) / $total]"