From af1c707eb8abf2da00ee6316452b9804e63ef1bf Mon Sep 17 00:00:00 2001
From: feat <featzhang@outlook.com>
Date: Tue, 23 Apr 2024 22:06:54 +0800
Subject: [PATCH] dev

---
 .../sort-flink-v1.15/sort-connectors/paimon/pom.xml           | 4 ++++
 .../sort/paimon/table/sink/PaimonTableInlongFactory.java      | 4 ++--
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/paimon/pom.xml b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/paimon/pom.xml
index 1c549e8de20..c39b7c57b75 100644
--- a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/paimon/pom.xml
+++ b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/paimon/pom.xml
@@ -43,6 +43,10 @@
             <groupId>org.apache.paimon</groupId>
             <artifactId>paimon-bundle</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.apache.paimon</groupId>
+            <artifactId>paimon-flink-1.15</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.apache.thrift</groupId>
             <artifactId>libfb303</artifactId>
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 597858a1db9..54bcaeb54d9 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
@@ -20,7 +20,7 @@
 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.table.FileTableFactory;
+import org.apache.paimon.flink.FlinkTableFactory;
 
 import java.util.Set;
 
@@ -41,7 +41,7 @@ public String factoryIdentifier() {
     }
 
     @Override
-    public DynamicTableSink createDynamicTableSink(SinkWriter.Context context) {
+    public DynamicTableSink createDynamicTableSink(Context context) {
         return super.createDynamicTableSink(context);
     }