Github user ajbozarth commented on a diff in the pull request:
https://github.com/apache/spark/pull/19270#discussion_r142540750
--- Diff: core/src/main/scala/org/apache/spark/ui/exec/ExecutorsTab.scala
---
@@ -67,14 +68,13 @@ class ExecutorsListener(storageStatusListener:
StorageStatusListener, conf: Spar
extends SparkListener {
val executorToTaskSummary = LinkedHashMap[String, ExecutorTaskSummary]()
var executorEvents = new ListBuffer[SparkListenerEvent]()
+ val executorIdToAddress = mutable.HashMap[String, String]()
private val maxTimelineExecutors =
conf.getInt("spark.ui.timeline.executors.maximum", 1000)
private val retainedDeadExecutors =
conf.getInt("spark.ui.retainedDeadExecutors", 100)
def activeStorageStatusList: Seq[StorageStatus] =
storageStatusListener.storageStatusList
-
def deadStorageStatusList: Seq[StorageStatus] =
storageStatusListener.deadStorageStatusList
-
--- End diff --
Why remove these lines? They don't seem to be an issue
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
