Skip to content

Commit c8ef968

Browse files
committed
adding host as an index
1 parent d51602f commit c8ef968

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -109,6 +109,7 @@ private[spark] object TaskIndexNames {
109109
final val DURATION = "dur"
110110
final val ERROR = "err"
111111
final val EXECUTOR = "exe"
112+
final val HOST = "hst"
112113
final val EXEC_CPU_TIME = "ect"
113114
final val EXEC_RUN_TIME = "ert"
114115
final val GC_TIME = "gc"
@@ -165,6 +166,7 @@ private[spark] class TaskDataWrapper(
165166
val duration: Long,
166167
@KVIndexParam(value = TaskIndexNames.EXECUTOR, parent = TaskIndexNames.STAGE)
167168
val executorId: String,
169+
@KVIndexParam(value = TaskIndexNames.HOST, parent = TaskIndexNames.STAGE)
168170
val host: String,
169171
@KVIndexParam(value = TaskIndexNames.STATUS, parent = TaskIndexNames.STAGE)
170172
val status: String,

core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -999,7 +999,7 @@ private object ApiHelper {
999999
HEADER_STATUS -> TaskIndexNames.STATUS,
10001000
HEADER_LOCALITY -> TaskIndexNames.LOCALITY,
10011001
HEADER_EXECUTOR -> TaskIndexNames.EXECUTOR,
1002-
HEADER_HOST -> TaskIndexNames.EXECUTOR,
1002+
HEADER_HOST -> TaskIndexNames.HOST,
10031003
HEADER_LAUNCH_TIME -> TaskIndexNames.LAUNCH_TIME,
10041004
HEADER_DURATION -> TaskIndexNames.DURATION,
10051005
HEADER_SCHEDULER_DELAY -> TaskIndexNames.SCHEDULER_DELAY,

0 commit comments

Comments
 (0)