You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ai...@apache.org on 2017/08/21 17:26:23 UTC
hive git commit: HIVE-17357: Plugin jars are not properly added for
LocalHiveSparkClient (Aihua Xu, reviewed by Xuefu Zhang)
Repository: hive
Updated Branches:
refs/heads/master d012f8653 -> 78efa7a69
HIVE-17357: Plugin jars are not properly added for LocalHiveSparkClient (Aihua Xu, reviewed by Xuefu Zhang)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/78efa7a6
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/78efa7a6
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/78efa7a6
Branch: refs/heads/master
Commit: 78efa7a69b965f39a6f0883863052acbb0bc824c
Parents: d012f86
Author: Aihua Xu <ai...@apache.org>
Authored: Fri Aug 18 10:10:42 2017 -0700
Committer: Aihua Xu <ai...@apache.org>
Committed: Mon Aug 21 10:25:26 2017 -0700
----------------------------------------------------------------------
.../org/apache/hadoop/hive/ql/exec/spark/LocalHiveSparkClient.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/78efa7a6/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/LocalHiveSparkClient.java
----------------------------------------------------------------------
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 beeafd0..72f2f91 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 @@ public class LocalHiveSparkClient implements HiveSparkClient {
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);