Skip to content

Commit 3f90485

Browse files
authored
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
1 parent 334dba5 commit 3f90485

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -205,7 +205,6 @@ private boolean useHiveContext() {
205205
private boolean hiveClassesArePresent() {
206206
try {
207207
this.getClass().forName("org.apache.spark.sql.hive.HiveSessionState");
208-
this.getClass().forName("org.apache.spark.sql.hive.HiveSharedState");
209208
this.getClass().forName("org.apache.hadoop.hive.conf.HiveConf");
210209
return true;
211210
} catch (ClassNotFoundException | NoClassDefFoundError e) {
@@ -355,7 +354,7 @@ public Object createSparkSession() {
355354
new Class[]{ String.class, String.class},
356355
new Object[]{ "spark.sql.catalogImplementation", "in-memory"});
357356
sparkSession = Utils.invokeMethod(builder, "getOrCreate");
358-
logger.info("Created Spark session with Hive support");
357+
logger.info("Created Spark session with Hive support use in-memory catalogImplementation");
359358
}
360359
} else {
361360
sparkSession = Utils.invokeMethod(builder, "getOrCreate");

0 commit comments

Comments
 (0)