diff --git a/core/src/main/resources/org/apache/spark/ui/static/stagepage.js b/core/src/main/resources/org/apache/spark/ui/static/stagepage.js index a8792593bf236..3c9c38bd092ff 100644 --- a/core/src/main/resources/org/apache/spark/ui/static/stagepage.js +++ b/core/src/main/resources/org/apache/spark/ui/static/stagepage.js @@ -846,12 +846,7 @@ $(document).ready(function () { } }, "columns": [ - { - data: function (row, type) { - return type !== 'display' ? (isNaN(row.index) ? 0 : row.index ) : row.index; - }, - name: "Index" - }, + {data: "partitionId", name: "Index"}, {data : "taskId", name: "ID"}, {data : "attempt", name: "Attempt"}, {data : "status", name: "Status"}, diff --git a/core/src/main/resources/org/apache/spark/ui/static/stagespage-template.html b/core/src/main/resources/org/apache/spark/ui/static/stagespage-template.html index 699278e0c1681..86ec73e91a76c 100644 --- a/core/src/main/resources/org/apache/spark/ui/static/stagespage-template.html +++ b/core/src/main/resources/org/apache/spark/ui/static/stagespage-template.html @@ -54,7 +54,7 @@
Executor ID | Logs | Address | diff --git a/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala b/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala index d50ccdadff560..7b71c47698232 100644 --- a/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala +++ b/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala @@ -469,7 +469,7 @@ private[spark] object ApiHelper { private[ui] val COLUMN_TO_INDEX = Map( HEADER_ID -> null.asInstanceOf[String], - HEADER_TASK_INDEX -> TaskIndexNames.TASK_INDEX, + HEADER_TASK_INDEX -> TaskIndexNames.TASK_PARTITION_ID, HEADER_ATTEMPT -> TaskIndexNames.ATTEMPT, HEADER_STATUS -> TaskIndexNames.STATUS, HEADER_LOCALITY -> TaskIndexNames.LOCALITY,
---|