diff --git a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/paimon/src/main/java/org/apache/inlong/sort/paimon/table/sink/PaimonTableInlongFactory.java b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/paimon/src/main/java/org/apache/inlong/sort/paimon/table/sink/PaimonTableInlongFactory.java index 54bcaeb54d9..4306023e0d2 100644 --- a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/paimon/src/main/java/org/apache/inlong/sort/paimon/table/sink/PaimonTableInlongFactory.java +++ b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/paimon/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";