diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/HiveOpConverter.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/HiveOpConverter.java index c54a601..169c351 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/HiveOpConverter.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/HiveOpConverter.java @@ -605,7 +605,7 @@ private OpAttr genPTF(OpAttr inputOpAf, WindowingSpec wSpec) throws SemanticExce WindowingComponentizer groups = new WindowingComponentizer(wSpec); RowResolver rr = new RowResolver(); for (ColumnInfo ci : input.getSchema().getSignature()) { - rr.put(ci.getTabAlias(), ci.getInternalName(), ci); + rr.put(inputOpAf.tabAlias, ci.getInternalName(), ci); } while (groups.hasNext()) {