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 778b2fd5512c..4089100ffdfe 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 DataStreamSink<?> build() {
         switch (bucketMode) {
             case HASH_FIXED:
             case HASH_DYNAMIC:
+            case KEY_DYNAMIC:
                 return buildForBucketAware();
             default:
                 throw new UnsupportedOperationException("Unsupported bucket mode: " + bucketMode);