Repository: hive Updated Branches: refs/heads/master c34938b9d -> 408ea39b7
HIVE-18653: Fix TestOperators test failure in master (Prasanth Jayachandran reviewed by Deepak Jaiswal) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/408ea39b Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/408ea39b Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/408ea39b Branch: refs/heads/master Commit: 408ea39b7784639db5b0100fa51cf8aacb5f46a3 Parents: c34938b Author: Prasanth Jayachandran <prasan...@apache.org> Authored: Fri Feb 9 06:11:02 2018 -0800 Committer: Prasanth Jayachandran <prasan...@apache.org> Committed: Fri Feb 9 06:11:02 2018 -0800 ---------------------------------------------------------------------- ql/src/test/org/apache/hadoop/hive/ql/exec/TestOperators.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/408ea39b/ql/src/test/org/apache/hadoop/hive/ql/exec/TestOperators.java ---------------------------------------------------------------------- diff --git a/ql/src/test/org/apache/hadoop/hive/ql/exec/TestOperators.java b/ql/src/test/org/apache/hadoop/hive/ql/exec/TestOperators.java index df19d72..635a357 100644 --- a/ql/src/test/org/apache/hadoop/hive/ql/exec/TestOperators.java +++ b/ql/src/test/org/apache/hadoop/hive/ql/exec/TestOperators.java @@ -453,6 +453,11 @@ public class TestOperators extends TestCase { hiveConf, llapInfo).getAdjustedNoConditionalTaskSize()); hiveConf.set(HiveConf.ConfVars.HIVE_EXECUTION_MODE.varname, "llap"); + if ("llap".equalsIgnoreCase(hiveConf.getVar(HiveConf.ConfVars.HIVE_EXECUTION_MODE))) { + llapInfo = LlapClusterStateForCompile.getClusterInfo(hiveConf); + llapInfo.initClusterInfo(); + } + // default executors is 4, max slots is 3. so 3 * 20% of noconditional task size will be oversubscribed hiveConf.set(HiveConf.ConfVars.LLAP_MAPJOIN_MEMORY_OVERSUBSCRIBE_FACTOR.varname, "0.2"); double fraction = hiveConf.getFloatVar(HiveConf.ConfVars.LLAP_MAPJOIN_MEMORY_OVERSUBSCRIBE_FACTOR);
