Skip to content

Commit f3b6bd7

Browse files
committed
Fix metrics typos in PushGatewaySink
1 parent 9ce7cfe commit f3b6bd7

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

src/main/scala/ch/cern/sparkmeasure/PushGatewaySink.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ class PushGatewaySink(conf: SparkConf) extends SparkListener {
8888
"completionTime" -> completionTime,
8989
"failureReason" -> stageCompleted.stageInfo.failureReason.getOrElse(""),
9090
"executorRunTime" -> taskMetrics.executorRunTime,
91-
"executorCpuTime" -> taskMetrics.executorRunTime,
91+
"executorCpuTime" -> taskMetrics.executorCpuTime,
9292
"executorDeserializeCpuTime" -> taskMetrics.executorDeserializeCpuTime,
9393
"executorDeserializeTime" -> taskMetrics.executorDeserializeTime,
9494
"jvmGCTime" -> taskMetrics.jvmGCTime,

0 commit comments

Comments
 (0)