From 748578978d6e984e46f01eadaf3f3a20159c2db2 Mon Sep 17 00:00:00 2001
From: yangjf2019 <highfei2011@outlook.com>
Date: Mon, 13 Jan 2025 11:38:45 +0800
Subject: [PATCH] [hotfix] fix some typos

---
 .../apache/paimon/flink/sink/CombinedTableCompactorSink.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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,