From 18465ab3a93db191540a163d5291d6b365fc17df Mon Sep 17 00:00:00 2001 From: feat Date: Tue, 23 Apr 2024 23:19:34 +0800 Subject: [PATCH] dev --- .../sort/paimon/table/sink/PaimonTableInlongFactory.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) 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";