dev

featzhang · Apr 23, 2024 · 18465ab · 18465ab
1 parent 48fb188
commit 18465ab
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...imon/src/main/java/org/apache/inlong/sort/paimon/table/sink/PaimonTableInlongFactory.java b/...imon/src/main/java/org/apache/inlong/sort/paimon/table/sink/PaimonTableInlongFactory.java
@@ -17,7 +17,6 @@
 
 package org.apache.inlong.sort.paimon.table.sink;
 
-import org.apache.flink.api.connector.sink2.SinkWriter;
 import org.apache.flink.configuration.ConfigOption;
 import org.apache.flink.table.connector.sink.DynamicTableSink;
 import org.apache.paimon.flink.FlinkTableFactory;
@@ -27,7 +26,7 @@
 import static org.apache.inlong.sort.base.Constants.INLONG_AUDIT;
 import static org.apache.inlong.sort.base.Constants.INLONG_METRIC;
 
-public class PaimonTableInlongFactory extends FlinkTableFactory{
+public class PaimonTableInlongFactory extends FlinkTableFactory {
 
     public static final String SORT_CONNECTOR_IDENTIFY_PAIMON = "paimon-inlong";