Repository: hive Updated Branches: refs/heads/branch-1.2 c37d18fba -> 8dd3bef56 refs/heads/master 61176b10c -> 6b471dab6
HIVE-10549 : CBO (Calcite Return Path): Enable NonBlockingOpDeDupProc (Pengcheng Xiong via Ashutosh Chauhan) Signed-off-by: Ashutosh Chauhan <hashut...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/6b471dab Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/6b471dab Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/6b471dab Branch: refs/heads/master Commit: 6b471dab6fa4adea12bd102864611b4c20f1f0f2 Parents: 61176b1 Author: Pengcheng Xiong <pxi...@hortonworks.com> Authored: Wed Apr 29 22:25:00 2015 -0700 Committer: Ashutosh Chauhan <hashut...@apache.org> Committed: Fri May 1 11:32:33 2015 -0700 ---------------------------------------------------------------------- ql/src/java/org/apache/hadoop/hive/ql/optimizer/Optimizer.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/6b471dab/ql/src/java/org/apache/hadoop/hive/ql/optimizer/Optimizer.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/Optimizer.java b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/Optimizer.java index 5afd4f2..58f8afe 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/Optimizer.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/Optimizer.java @@ -149,9 +149,7 @@ public class Optimizer { if(HiveConf.getBoolVar(hiveConf, HiveConf.ConfVars.HIVEOPTREDUCEDEDUPLICATION)) { transformations.add(new ReduceSinkDeDuplication()); } - if(!HiveConf.getBoolVar(hiveConf, HiveConf.ConfVars.HIVE_CBO_RETPATH_HIVEOP)) { - transformations.add(new NonBlockingOpDeDupProc()); - } + transformations.add(new NonBlockingOpDeDupProc()); if (HiveConf.getBoolVar(hiveConf, HiveConf.ConfVars.HIVEIDENTITYPROJECTREMOVER) && !HiveConf.getBoolVar(hiveConf, HiveConf.ConfVars.HIVE_CBO_RETPATH_HIVEOP)) { transformations.add(new IdentityProjectRemover());
