diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkClient.java ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkClient.java index 0020c92..d7a23a9 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkClient.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkClient.java @@ -178,7 +178,7 @@ public int execute(DriverContext driverContext, SparkWork sparkWork) { */ private synchronized void refreshLocalResources(SparkWork sparkWork, HiveConf conf) { // add hive-exec jar - addJars(conf.getJar()); + addJars((new JobConf(this.getClass())).getJar()); // add aux jars addJars(HiveConf.getVar(conf, HiveConf.ConfVars.HIVEAUXJARS));