This is an automated email from the ASF dual-hosted git repository. jark pushed a commit to branch release-0.9 in repository https://gitbox.apache.org/repos/asf/fluss.git
commit 9290821287b1ceafd668ef7a98959fb949b9099e Author: Jark Wu <[email protected]> AuthorDate: Wed Feb 18 09:15:17 2026 +0800 [hotfix][flink] Fix COUNT(*) aggregation produces wrong result for legacy clusters (#2690) --- .../src/main/java/org/apache/fluss/flink/utils/PushdownUtils.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/utils/PushdownUtils.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/utils/PushdownUtils.java index 370782607..455d1f365 100644 --- a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/utils/PushdownUtils.java +++ b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/utils/PushdownUtils.java @@ -392,6 +392,10 @@ public class PushdownUtils { */ private static long countLogTable(Admin flussAdmin, TablePath tablePath) throws Exception { TableInfo tableInfo = flussAdmin.getTableInfo(tablePath).get(); + if (tableInfo.hasPrimaryKey()) { + throw new IllegalArgumentException( + "The Fluss cluster doesn't support count(*) on primary key table yet. Please upgrade to newer version (≥ 0.9)."); + } int bucketCount = tableInfo.getNumBuckets(); Collection<Integer> buckets = IntStream.range(0, bucketCount).boxed().collect(Collectors.toList());
