diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/LocalHiveSparkClient.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/LocalHiveSparkClient.java index beeafd0672..72f2f918db 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/LocalHiveSparkClient.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/LocalHiveSparkClient.java @@ -178,7 +178,7 @@ private synchronized void refreshLocalResources(SparkWork sparkWork, HiveConf co for (BaseWork work : sparkWork.getAllWork()) { work.configureJobConf(jobConf); } - addJars(conf.get(MR_JAR_PROPERTY)); + addJars(jobConf.get(MR_JAR_PROPERTY)); // add added files String addedFiles = Utilities.getResourceFiles(conf, SessionState.ResourceType.FILE);