Skip to content

Commit

Permalink
Update SparkConsoleProgressBar.scala
Browse files Browse the repository at this point in the history
update desc about findJob
  • Loading branch information
davidyuan1223 authored Oct 18, 2023
1 parent 8c04dca commit 9e46356
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -75,8 +75,8 @@ class SparkConsoleProgressBar(

/**
* Use stageId to find stage's jobId
* @param stageId stageId
* @return jobId,if not exists, return -1
* @param stageId
* @return Optional jobId
*/
private def findJobId(stageId: Int): Option[Int] = {
liveJobs.asScala.collectFirst {
Expand Down

0 comments on commit 9e46356

Please sign in to comment.