(fluss) branch main updated: [hotfix][flink] Fix COUNT(*) aggregation produces wrong result for legacy clusters (#2690)

[jark]

This is an automated email from the ASF dual-hosted git repository.

jark pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 3fb96b3de [hotfix][flink] Fix COUNT(*) aggregation produces wrong 
result for legacy clusters (#2690)
3fb96b3de is described below

commit 3fb96b3de25d15b58f79bfe67b787db450b59f41
Author: Jark Wu <j...@apache.org>
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());