Skip to content

Commit 017c755

Browse files
committed
add in metrics now available
1 parent 1b78cb7 commit 017c755

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

core/src/main/scala/org/apache/spark/status/api/v1/AllStagesResource.scala

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -95,13 +95,13 @@ object AllStagesResource {
9595
numFailedTasks = stageUiData.numFailedTasks,
9696
executorRunTime = stageUiData.executorRunTime,
9797
inputBytes = stageUiData.inputBytes,
98-
inputRecords = 0, //fix after SPARK-4874
98+
inputRecords = stageUiData.inputRecords,
9999
outputBytes = stageUiData.outputBytes,
100-
outputRecords = 0, //fix after SPARK-4874
100+
outputRecords = stageUiData.outputRecords,
101101
shuffleReadBytes = stageUiData.shuffleReadTotalBytes,
102-
shuffleReadRecords = 0, //fix after SPARK-4874
102+
shuffleReadRecords = stageUiData.shuffleReadRecords,
103103
shuffleWriteBytes = stageUiData.shuffleWriteBytes,
104-
shuffleWriteRecords = 0, //fix after SPARK-4874
104+
shuffleWriteRecords = stageUiData.shuffleWriteRecords,
105105
memoryBytesSpilled = stageUiData.memoryBytesSpilled,
106106
diskBytesSpilled = stageUiData.diskBytesSpilled,
107107
schedulingPool = stageUiData.schedulingPool,
@@ -159,14 +159,14 @@ object AllStagesResource {
159159
def convertInputMetrics(internal: InternalInputMetrics): InputMetrics = {
160160
InputMetrics(
161161
bytesRead = internal.bytesRead,
162-
recordsRead = 0 //fix after SPARK-4874
162+
recordsRead = internal.recordsRead
163163
)
164164
}
165165

166166
def convertOutputMetrics(internal: InternalOutputMetrics): OutputMetrics = {
167167
OutputMetrics(
168168
bytesWritten = internal.bytesWritten,
169-
recordsWritten = 0 //fix after SPARK-4874
169+
recordsWritten = internal.recordsWritten
170170
)
171171
}
172172

@@ -177,16 +177,16 @@ object AllStagesResource {
177177
fetchWaitTime = internal.fetchWaitTime,
178178
remoteBytesRead = internal.remoteBytesRead,
179179
totalBlocksFetched = internal.totalBlocksFetched,
180-
recordsRead = 0 //fix after SPARK-4874
180+
recordsRead = internal.recordsRead
181181
)
182182
}
183183

184184
def convertShuffleWriteMetrics(internal: InternalShuffleWriteMetrics): ShuffleWriteMetrics = {
185185
ShuffleWriteMetrics(
186186
bytesWritten = internal.shuffleBytesWritten,
187187
writeTime = internal.shuffleWriteTime,
188-
recordsWritten = 0 //fix after SPARK-4874
188+
recordsWritten = internal.shuffleRecordsWritten
189189
)
190190
}
191191

192-
}
192+
}

0 commit comments

Comments
 (0)