From e89c45fbea700c5eb9ab6032ec52ddee2828e555 Mon Sep 17 00:00:00 2001 From: Tom Zeng Date: Thu, 5 Nov 2015 16:48:27 -0800 Subject: [PATCH] HIVE-11795 : add missing overides required by Spark 1.5.x --- .../hadoop/hive/ql/exec/spark/status/impl/JobMetricsListener.java | 4 ++++ .../src/main/java/org/apache/hive/spark/client/RemoteDriver.java | 4 ++++ 2 files changed, 8 insertions(+) diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/status/impl/JobMetricsListener.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/status/impl/JobMetricsListener.java index 84603d5..757ea8c 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/status/impl/JobMetricsListener.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/status/impl/JobMetricsListener.java @@ -41,6 +41,7 @@ import org.apache.spark.scheduler.SparkListenerUnpersistRDD; import org.apache.spark.scheduler.SparkListenerExecutorRemoved; import org.apache.spark.scheduler.SparkListenerExecutorAdded; +import org.apache.spark.scheduler.SparkListenerBlockUpdated; import com.google.common.collect.Lists; import com.google.common.collect.Maps; @@ -158,6 +159,9 @@ public void onApplicationEnd(SparkListenerApplicationEnd applicationEnd) { public void onExecutorMetricsUpdate(SparkListenerExecutorMetricsUpdate executorMetricsUpdate) { } + + @Override + public void onBlockUpdated(SparkListenerBlockUpdated blockUpdated) {} public synchronized Map> getJobMetric(int jobId) { return allJobMetrics.get(jobId); diff --git a/spark-client/src/main/java/org/apache/hive/spark/client/RemoteDriver.java b/spark-client/src/main/java/org/apache/hive/spark/client/RemoteDriver.java index b77c9e8..b4e09c1 100644 --- a/spark-client/src/main/java/org/apache/hive/spark/client/RemoteDriver.java +++ b/spark-client/src/main/java/org/apache/hive/spark/client/RemoteDriver.java @@ -63,6 +63,7 @@ import org.apache.spark.scheduler.SparkListenerUnpersistRDD; import org.apache.spark.scheduler.SparkListenerExecutorRemoved; import org.apache.spark.scheduler.SparkListenerExecutorAdded; +import org.apache.spark.scheduler.SparkListenerBlockUpdated; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -532,6 +533,9 @@ public void onApplicationEnd(SparkListenerApplicationEnd applicationEnd) { } @Override public void onExecutorMetricsUpdate(SparkListenerExecutorMetricsUpdate executorMetricsUpdate) { } + + @Override + public void onBlockUpdated(SparkListenerBlockUpdated blockUpdated) {} /** * Returns the client job ID for the given Spark job ID. -- 1.9.5 (Apple Git-50.3)