Skip to content
Snippets Groups Projects
Commit 0afe5cb6 authored by Sandy Ryza's avatar Sandy Ryza Committed by Patrick Wendell
Browse files

SPARK-3028. sparkEventToJson should support SparkListenerExecutorMetrics...

...Update

Author: Sandy Ryza <sandy@cloudera.com>

Closes #1961 from sryza/sandy-spark-3028 and squashes the following commits:

dccdff5 [Sandy Ryza] Fix compile error
f883ded [Sandy Ryza] SPARK-3028. sparkEventToJson should support SparkListenerExecutorMetricsUpdate
parent fd9fcd25
No related branches found
No related tags found
No related merge requests found
...@@ -127,6 +127,8 @@ private[spark] class EventLoggingListener( ...@@ -127,6 +127,8 @@ private[spark] class EventLoggingListener(
logEvent(event, flushLogger = true) logEvent(event, flushLogger = true)
override def onApplicationEnd(event: SparkListenerApplicationEnd) = override def onApplicationEnd(event: SparkListenerApplicationEnd) =
logEvent(event, flushLogger = true) logEvent(event, flushLogger = true)
// No-op because logging every update would be overkill
override def onExecutorMetricsUpdate(event: SparkListenerExecutorMetricsUpdate) { }
/** /**
* Stop logging events. * Stop logging events.
......
...@@ -72,8 +72,9 @@ private[spark] object JsonProtocol { ...@@ -72,8 +72,9 @@ private[spark] object JsonProtocol {
case applicationEnd: SparkListenerApplicationEnd => case applicationEnd: SparkListenerApplicationEnd =>
applicationEndToJson(applicationEnd) applicationEndToJson(applicationEnd)
// Not used, but keeps compiler happy // These aren't used, but keeps compiler happy
case SparkListenerShutdown => JNothing case SparkListenerShutdown => JNothing
case SparkListenerExecutorMetricsUpdate(_, _) => JNothing
} }
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment