address comment.

apache · Oct 24, 2024 · 0466c19 · 0466c19
1 parent 29c064a
commit 0466c19
Showing 1 changed file with 2 additions and 32 deletions.
diff --git a/...-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonCommitter.java b/...-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonCommitter.java
@@ -17,9 +17,7 @@
 
 package org.apache.flink.cdc.connectors.paimon.sink.v2;
 
-import org.apache.flink.api.common.state.OperatorStateStore;
 import org.apache.flink.api.connector.sink2.Committer;
-import org.apache.flink.metrics.groups.OperatorMetricGroup;
 
 import org.apache.paimon.flink.FlinkCatalogFactory;
 import org.apache.paimon.flink.sink.MultiTableCommittable;
@@ -29,8 +27,6 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import javax.annotation.Nullable;
-
 import java.util.Collection;
 import java.util.Collections;
 import java.util.List;
@@ -48,34 +44,8 @@ public PaimonCommitter(Options catalogOptions, String commitUser) {
         storeMultiCommitter =
                 new StoreMultiCommitter(
                         () -> FlinkCatalogFactory.createPaimonCatalog(catalogOptions),
-                        new org.apache.paimon.flink.sink.Committer.Context() {
-
-                            @Override
-                            public String commitUser() {
-                                return commitUser;
-                            }
-
-                            @Nullable
-                            @Override
-                            public OperatorMetricGroup metricGroup() {
-                                return null;
-                            }
-
-                            @Override
-                            public boolean streamingCheckpointEnabled() {
-                                return false;
-                            }
-
-                            @Override
-                            public boolean isRestored() {
-                                return false;
-                            }
-
-                            @Override
-                            public OperatorStateStore stateStore() {
-                                return null;
-                            }
-                        });
+                        org.apache.paimon.flink.sink.Committer.createContext(
+                                commitUser, null, true, false, null));
     }
 
     @Override