Skip to content

Commit f883ded

Browse files
committed
SPARK-3028. sparkEventToJson should support SparkListenerExecutorMetricsUpdate
1 parent 9422a9b commit f883ded

File tree

2 files changed

+4
-1
lines changed

2 files changed

+4
-1
lines changed

core/src/main/scala/org/apache/spark/scheduler/EventLoggingListener.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -127,6 +127,8 @@ private[spark] class EventLoggingListener(
127127
logEvent(event, flushLogger = true)
128128
override def onApplicationEnd(event: SparkListenerApplicationEnd) =
129129
logEvent(event, flushLogger = true)
130+
// No-op because logging every update would be overkill
131+
override def onExecutorMetricsUpdate(event: SparkListenerExecutorMetricsUpdate) { }
130132

131133
/**
132134
* Stop logging events.

core/src/main/scala/org/apache/spark/util/JsonProtocol.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,8 +72,9 @@ private[spark] object JsonProtocol {
7272
case applicationEnd: SparkListenerApplicationEnd =>
7373
applicationEndToJson(applicationEnd)
7474

75-
// Not used, but keeps compiler happy
75+
// These aren't used, but keeps compiler happy
7676
case SparkListenerShutdown => JNothing
77+
case SparkListenerExecutorMetricsUpdate => JNothing
7778
}
7879
}
7980

0 commit comments

Comments
 (0)