KYLIN-2530 pass hive configuration along with MR job
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/7cb88f5f Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/7cb88f5f Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/7cb88f5f Branch: refs/heads/master-hbase0.98 Commit: 7cb88f5f971535cdd43292c624c3a3f08faadcdf Parents: 551f5ed Author: Yang Li <liy...@apache.org> Authored: Tue Apr 4 16:55:53 2017 +0800 Committer: Yang Li <liy...@apache.org> Committed: Tue Apr 4 16:56:12 2017 +0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/kylin/source/hive/HiveMRInput.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/7cb88f5f/source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java ---------------------------------------------------------------------- diff --git a/source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java b/source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java index bbf3c60..a5d1353 100644 --- a/source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java +++ b/source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java @@ -107,6 +107,8 @@ public class HiveMRInput implements IMRInput { @Override public void configureJob(Job job) { try { + job.getConfiguration().addResource("hive-site.xml"); + HCatInputFormat.setInput(job, dbName, tableName); job.setInputFormatClass(HCatInputFormat.class);
