diff options
| author | Reynold Xin <rxin@databricks.com> | 2016-04-04 13:26:18 -0700 |
|---|---|---|
| committer | Andrew Or <andrew@databricks.com> | 2016-04-04 13:26:18 -0700 |
| commit | 7143904700435265975d36f073cce2833467e121 (patch) | |
| tree | 1e8778c194afa169572d7a1cd947bfbc62105b3f /streaming | |
| parent | 27dad6f658f04815e1f3b93c68974bfd31500bed (diff) | |
| download | spark-7143904700435265975d36f073cce2833467e121.tar.gz spark-7143904700435265975d36f073cce2833467e121.tar.bz2 spark-7143904700435265975d36f073cce2833467e121.zip | |
[SPARK-14358] Change SparkListener from a trait to an abstract class
## What changes were proposed in this pull request?
Scala traits are difficult to maintain binary compatibility on, and as a result we had to introduce JavaSparkListener. In Spark 2.0 we can change SparkListener from a trait to an abstract class and then remove JavaSparkListener.
## How was this patch tested?
Updated related unit tests.
Author: Reynold Xin <rxin@databricks.com>
Closes #12142 from rxin/SPARK-14358.
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingJobProgressListener.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingJobProgressListener.scala b/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingJobProgressListener.scala index 6985c37f71..c086df47d9 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingJobProgressListener.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingJobProgressListener.scala @@ -28,7 +28,7 @@ import org.apache.spark.streaming.{StreamingContext, Time} import org.apache.spark.streaming.scheduler._ private[streaming] class StreamingJobProgressListener(ssc: StreamingContext) - extends StreamingListener with SparkListener { + extends SparkListener with StreamingListener { private val waitingBatchUIData = new HashMap[Time, BatchUIData] private val runningBatchUIData = new HashMap[Time, BatchUIData] |