address comment.

Author: lvyanquan

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-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