This is an automated email from the ASF dual-hosted git repository. snuyanzin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 66ca7c54a6e0ce53ba4177e127997c1979deae48 Author: Sergey Nuyanzin <[email protected]> AuthorDate: Sat Jul 4 09:45:29 2026 +0200 [FLINK-39859][table] Remove usage of deprecated `getIndicatorCount` --- .../planner/plan/rules/logical/FlinkAggregateJoinTransposeRule.java | 2 +- .../org/apache/flink/table/planner/plan/utils/FlinkRelMdUtil.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkAggregateJoinTransposeRule.java b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkAggregateJoinTransposeRule.java index cbb6f44de91..75d8b5a3154 100644 --- a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkAggregateJoinTransposeRule.java +++ b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkAggregateJoinTransposeRule.java @@ -403,7 +403,7 @@ public class FlinkAggregateJoinTransposeRule extends RelOptRule { // Aggregate above to sum up the sub-totals final List<AggregateCall> newAggCalls = new ArrayList<>(); - final int groupIndicatorCount = aggregate.getGroupCount() + aggregate.getIndicatorCount(); + final int groupIndicatorCount = aggregate.getGroupCount(); final int newLeftWidth = sides.get(0).newInput.getRowType().getFieldCount(); final List<RexNode> projects = new ArrayList<>(rexBuilder.identityProjects(relBuilder.peek().getRowType())); diff --git a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRelMdUtil.scala b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRelMdUtil.scala index c2d4712c24c..c28ed3f48a8 100644 --- a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRelMdUtil.scala +++ b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRelMdUtil.scala @@ -326,7 +326,7 @@ object FlinkRelMdUtil { childKeyBuilder.set(fullGroupSet(bit)) } else if (!containsAllAggGroupKeys) { // getIndicatorCount return 0 if auxGroupSet is not empty - val agg = otherAggCalls.asJava.get(bit - (fullGroupSet.length + aggRel.getIndicatorCount)) + val agg = otherAggCalls.asJava.get(bit - fullGroupSet.length) aggCalls += agg }) (childKeyBuilder.build(), aggCalls.toArray)
