diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HiveSparkClientFactory.java ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HiveSparkClientFactory.java index 993d02b..1798622 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HiveSparkClientFactory.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HiveSparkClientFactory.java @@ -146,7 +146,7 @@ public static HiveSparkClient createHiveSparkClient(HiveConf hiveconf) throws Ex if (value != null && !value.isEmpty()) { sparkConf.put("spark.hadoop." + propertyName, value); } - } else if (propertyName.startsWith("hbase")) { + } else if (propertyName.startsWith("hbase") || propertyName.startsWith("zookeeper.znode")) { // Add HBase related configuration to Spark because in security mode, Spark needs it // to generate hbase delegation token for Spark. This is a temp solution to deal with // Spark problem.