diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/GlobalWorkMapFactory.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/GlobalWorkMapFactory.java index c381c77..f3d8209 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/GlobalWorkMapFactory.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/GlobalWorkMapFactory.java @@ -81,11 +81,8 @@ public int size() { DummyMap dummy = new DummyMap(); public Map get(Configuration conf) { - if (LlapIoProxy.isDaemon()) { - return dummy; - } - - if (HiveConf.getVar(conf, ConfVars.HIVE_EXECUTION_ENGINE).equals("spark")) { + if (LlapIoProxy.isDaemon() + || HiveConf.getVar(conf, ConfVars.HIVE_EXECUTION_ENGINE).equals("spark")) { if (threadLocalWorkMap == null) { threadLocalWorkMap = new ThreadLocal>() { @Override