KYLIN-2693 Should use overrideHiveConfig for LookupHiveViewMaterialization and RedistributeFlatHiveTable
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/772a95f3 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/772a95f3 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/772a95f3 Branch: refs/heads/KYLIN-2606 Commit: 772a95f3a0aaafca5260140c461edb053990cfe8 Parents: 547722d Author: kangkaisen <kangkai...@live.com> Authored: Tue Jun 27 20:02:04 2017 +0800 Committer: kangkaisen <kangkai...@live.com> Committed: Thu Jun 29 21:17:45 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/772a95f3/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 337bafd..4747cb9 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 @@ -206,6 +206,7 @@ public class HiveMRInput implements IMRInput { } HiveCmdBuilder hiveCmdBuilder = new HiveCmdBuilder(); + hiveCmdBuilder.overwriteHiveProps(kylinConfig.getHiveConfigOverride()); hiveCmdBuilder.addStatement(hiveInitStatements); for (TableDesc lookUpTableDesc : lookupViewsTables) { String identity = lookUpTableDesc.getIdentity(); @@ -273,6 +274,7 @@ public class HiveMRInput implements IMRInput { private void redistributeTable(KylinConfig config, int numReducers) throws IOException { final HiveCmdBuilder hiveCmdBuilder = new HiveCmdBuilder(); + hiveCmdBuilder.overwriteHiveProps(config.getHiveConfigOverride()); hiveCmdBuilder.addStatement(getInitStatement()); hiveCmdBuilder.addStatement("set mapreduce.job.reduces=" + numReducers + ";\n"); hiveCmdBuilder.addStatement("set hive.merge.mapredfiles=false;\n");
