(paimon) branch master updated: [Fix] Support KEY_DYNAMIC bucket mode in CompactorSinkBuilder (#9338)

[lzljs3620320]

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

JingsongLi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new e35d1a6152 [Fix] Support KEY_DYNAMIC bucket mode in 
CompactorSinkBuilder (#9338)
e35d1a6152 is described below

commit e35d1a6152c6743bd50dcc7a52104da9e43a272e
Author: 张万义 <31638790+zhang-ar...@users.noreply.github.com>
AuthorDate: Sun Aug 23 23:21:46 2026 +0800

    [Fix] Support KEY_DYNAMIC bucket mode in CompactorSinkBuilder (#9338)
---
 .../src/main/java/org/apache/paimon/flink/sink/CompactorSinkBuilder.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CompactorSinkBuilder.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CompactorSinkBuilder.java
index 778b2fd551..4089100ffd 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CompactorSinkBuilder.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CompactorSinkBuilder.java
@@ -66,6 +66,7 @@ public class CompactorSinkBuilder {
         switch (bucketMode) {
             case HASH_FIXED:
             case HASH_DYNAMIC:
+            case KEY_DYNAMIC:
                 return buildForBucketAware();
             default:
                 throw new UnsupportedOperationException("Unsupported bucket 
mode: " + bucketMode);