minor update

Author: shahidki31

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

@@ -731,8 +731,8 @@ private object LiveEntityHelpers {
   def makeNegative(m: v1.TaskMetrics): v1.TaskMetrics = {
     // To handle 0 metric value, add  1 and make the metric negative.
     // To recover actual value do `math.abs(metric + 1)`
-    // Eg: if the metric values are (5, 3, 0, 1) => Updated metrics value will be (-6, -4, -1, -2)
-    // To get actual metric value math.abs(metric +1) => (5, 3, 0, 1)
+    // Eg: if the metric values are (5, 3, 0, 1) => Updated metric values will be (-6, -4, -1, -2)
+    // To get actual metric value, do math.abs(metric + 1) => (5, 3, 0, 1)
     def updateMetricValue(metric: Long): Long = {
       metric * -1L - 1L
     }

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

@@ -137,7 +137,6 @@ private[spark] object TaskIndexNames {
   final val SHUFFLE_WRITE_RECORDS = "swr"
   final val SHUFFLE_WRITE_SIZE = "sws"
   final val SHUFFLE_WRITE_TIME = "swt"
-  final val SHUFFLE_LOCAL_READ = "slr"
   final val STAGE = "stage"
   final val STATUS = "sta"
   final val TASK_INDEX = "idx"

core/src/test/scala/org/apache/spark/status/AppStatusStoreSuite.scala

@@ -131,6 +131,16 @@ class AppStatusStoreSuite extends SparkFunSuite {
     }
   }
 
+
+  test("SPARK-26260: task summary size for default metrics should be zero") {
+    val store = new InMemoryStore()
+    store.write(newTaskData(-1, status = "RUNNING"))
+    Seq(new AppStatusStore(store), createLiveStore(store)).foreach { appStore =>
+      val summary = appStore.taskSummary(stageId, attemptId, uiQuantiles)
+      assert(summary.size === 0)
+    }
+  }
+
   test("SPARK-26260: summary should contain successful tasks only when with LevelDB store") {
     val testDir = Utils.createTempDir()
     val diskStore = KVUtils.open(testDir, getClass().getName())
@@ -157,15 +167,6 @@ class AppStatusStoreSuite extends SparkFunSuite {
     Utils.deleteRecursively(testDir)
   }
 
-  test("SPARK-26260: task summary size for default metrics should be zero") {
-    val store = new InMemoryStore()
-    store.write(newTaskData(-1, status = "RUNNING"))
-    Seq(new AppStatusStore(store), createLiveStore(store)).foreach { appStore =>
-      val summary = appStore.taskSummary(stageId, attemptId, uiQuantiles)
-      assert(summary.size === 0)
-    }
-  }
-
   private def compareQuantiles(count: Int, quantiles: Array[Double]): Unit = {
     val store = new InMemoryStore()
     val values = (0 until count).map { i =>