You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sn...@apache.org on 2026/07/06 18:47:45 UTC
(flink) 06/08: [FLINK-39859][table] Remove usage of deprecated `getIndicatorCount`
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 <sn...@gmail.com>
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)