diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CombinedTableCompactorSink.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CombinedTableCompactorSink.java
index 53f1bf165d98..1106add7d3fa 100644
--- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CombinedTableCompactorSink.java
+++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CombinedTableCompactorSink.java
@@ -107,7 +107,7 @@ public DataStream<MultiTableCommittable> doWrite(
                         .transform(
                                 String.format("%s-%s", "Multi-Bucket-Table", WRITER_NAME),
                                 new MultiTableCommittableTypeInfo(),
-                                combinedMultiComacptionWriteOperator(
+                                combinedMultiCompactionWriteOperator(
                                         env.getCheckpointConfig(),
                                         isStreaming,
                                         fullCompaction,
@@ -176,7 +176,7 @@ protected DataStreamSink<?> doCommit(
 
     // TODO:refactor FlinkSink to adopt this sink
     protected OneInputStreamOperatorFactory<RowData, MultiTableCommittable>
-            combinedMultiComacptionWriteOperator(
+            combinedMultiCompactionWriteOperator(
                     CheckpointConfig checkpointConfig,
                     boolean isStreaming,
                     boolean fullCompaction,