From 3f90485d1c05d863c6957f6ae9879b7491fb2bfa Mon Sep 17 00:00:00 2001 From: lichenglin Date: Fri, 6 Jan 2017 14:38:04 +0800 Subject: [PATCH] make hive enable under spark 2.1.0 remove org.apache.spark.sql.hive.HiveSharedState class check . Because this class has been removed from spark since 2.1.0 https://issues.apache.org/jira/browse/ZEPPELIN-1909 --- .../main/java/org/apache/zeppelin/spark/SparkInterpreter.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java b/spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java index e8c76bcccd4..301dd230ba1 100644 --- a/spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java +++ b/spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java @@ -205,7 +205,6 @@ private boolean useHiveContext() { private boolean hiveClassesArePresent() { try { this.getClass().forName("org.apache.spark.sql.hive.HiveSessionState"); - this.getClass().forName("org.apache.spark.sql.hive.HiveSharedState"); this.getClass().forName("org.apache.hadoop.hive.conf.HiveConf"); return true; } catch (ClassNotFoundException | NoClassDefFoundError e) { @@ -355,7 +354,7 @@ public Object createSparkSession() { new Class[]{ String.class, String.class}, new Object[]{ "spark.sql.catalogImplementation", "in-memory"}); sparkSession = Utils.invokeMethod(builder, "getOrCreate"); - logger.info("Created Spark session with Hive support"); + logger.info("Created Spark session with Hive support use in-memory catalogImplementation"); } } else { sparkSession = Utils.invokeMethod(builder, "getOrCreate");