diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/TezCompiler.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/TezCompiler.java index 7d5807720b..bf58bd8bb8 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/TezCompiler.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/TezCompiler.java @@ -1966,9 +1966,6 @@ private void updateBucketingVersionForUpgrade(OptimizeTezProcContext procCtx) { for (FileSinkOperator fsOp : fsOpsAll) { - if (!fsOp.getConf().getTableInfo().isSetBucketingVersion()) { - continue; - } // Look for direct parent ReduceSinkOp // If there are more than 1 parent, bail out. Operator parent = fsOp;