Skip to content

Commit ace04a5

Browse files
committed
remove duplicate code in AppStatusListener while assigning schedulingPool for stage
1 parent 9962390 commit ace04a5

File tree

1 file changed

+0
-4
lines changed

1 file changed

+0
-4
lines changed

core/src/main/scala/org/apache/spark/status/AppStatusListener.scala

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -329,10 +329,6 @@ private[spark] class AppStatusListener(
329329
.toSeq
330330
stage.jobIds = stage.jobs.map(_.jobId).toSet
331331

332-
stage.schedulingPool = Option(event.properties).flatMap { p =>
333-
Option(p.getProperty("spark.scheduler.pool"))
334-
}.getOrElse(SparkUI.DEFAULT_POOL_NAME)
335-
336332
stage.description = Option(event.properties).flatMap { p =>
337333
Option(p.getProperty(SparkContext.SPARK_JOB_DESCRIPTION))
338334
}

0 commit comments

Comments
 (0)