Feedback.

apache · Nov 16, 2017 · 81b3f3d · 81b3f3d
1 parent a004ce9
commit 81b3f3d
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/core/src/main/scala/org/apache/spark/SparkStatusTracker.scala b/core/src/main/scala/org/apache/spark/SparkStatusTracker.scala
@@ -105,10 +105,14 @@ class SparkStatusTracker private[spark] (sc: SparkContext, store: AppStatusStore
         case Array(h, p) => (h, p.toInt)
         case Array(h) => (h, -1)
       }
+      val cachedMem = exec.memoryMetrics.map { mem =>
+        mem.usedOnHeapStorageMemory + mem.usedOffHeapStorageMemory
+      }.getOrElse(0L)
+
       new SparkExecutorInfoImpl(
         host,
         port,
-        exec.maxMemory,
+        cachedMem,
         exec.activeTasks)
     }.toArray
   }

diff --git a/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala b/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala
@@ -294,8 +294,6 @@ private[history] class FsHistoryProvider(conf: SparkConf, clock: Clock)
       attempt.adminAclsGroups.getOrElse(""))
     secManager.setViewAclsGroups(attempt.viewAclsGroups.getOrElse(""))
 
-    val replayBus = new ReplayListenerBus()
-
     val uiStorePath = storePath.map { path => getStorePath(path, appId, attemptId) }
 
     val (kvstore, needReplay) = uiStorePath match {