-
- Downloads
[SPARK-14449][SQL] SparkContext should use SparkListenerInterface
Currently all `SparkFirehoseListener` implementations are broken since we expect listeners to extend `SparkListener`, while the fire hose only extends `SparkListenerInterface`. This changes the addListener function and the config based injection to use the interface instead. The existing tests in SparkListenerSuite are improved such that they would have caught this. Follow-up to #12142 Author: Michael Armbrust <michael@databricks.com> Closes #12227 from marmbrus/fixListener.
Showing
- core/src/main/scala/org/apache/spark/SparkContext.scala 5 additions, 3 deletionscore/src/main/scala/org/apache/spark/SparkContext.scala
- core/src/main/scala/org/apache/spark/scheduler/SparkListenerBus.scala 5 additions, 2 deletions...n/scala/org/apache/spark/scheduler/SparkListenerBus.scala
- core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala 16 additions, 3 deletions...scala/org/apache/spark/scheduler/SparkListenerSuite.scala
- project/MimaExcludes.scala 1 addition, 0 deletionsproject/MimaExcludes.scala
Loading
Please register or sign in to comment