From 424681ffdc9b00246408f2292e3a1875424358b0 Mon Sep 17 00:00:00 2001 From: kangkaisen Date: Tue, 27 Jun 2017 20:02:04 +0800 Subject: [PATCH] KYLIN-2693 Should use overrideHiveConfig for LookupHiveViewMaterialization and RedistributeFlatHiveTable --- source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java | 2 ++ 1 file changed, 2 insertions(+) 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 337bafd80..4747cb930 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"); -- 2.11.0 (Apple Git-81)