fix

yuzelin · Dec 1, 2023 · 2e3d0f2 · 2e3d0f2
1 parent 5408807
commit 2e3d0f2
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/...ink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaActionITCaseBase.java b/...ink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaActionITCaseBase.java
@@ -18,14 +18,12 @@
 
 package org.apache.paimon.flink.action.cdc.kafka;
 
-import org.apache.paimon.flink.action.MultipleParameterToolAdapter;
 import org.apache.paimon.flink.action.cdc.CdcActionITCaseBase;
 import org.apache.paimon.utils.StringUtils;
 
 import org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode;
 import org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.ObjectMapper;
 
-import org.apache.flink.api.java.utils.MultipleParameterTool;
 import org.apache.flink.util.DockerImageVersions;
 import org.apache.kafka.clients.CommonClientConfigs;
 import org.apache.kafka.clients.admin.AdminClient;
@@ -311,10 +309,6 @@ public KafkaSyncDatabaseAction build() {
 
             args.addAll(listToArgs("--type-mapping", typeMappingModes));
 
-            MultipleParameterToolAdapter params =
-                    new MultipleParameterToolAdapter(
-                            MultipleParameterTool.fromArgs(
-                                    args.toArray(args.toArray(new String[0]))));
             return createAction(KafkaSyncDatabaseAction.class, args);
         }
     }