dev

featzhang · Apr 23, 2024 · af1c707 · af1c707
1 parent bdb316d
commit af1c707
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 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
@@ -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/...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
@@ -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);
     }