[flink][cdc] Update flink dependency to 1.20 (#4580)

apache · Nov 25, 2024 · be24886 · be24886
1 parent 63551bb
commit be24886
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 58 deletions.
diff --git a/paimon-flink/paimon-flink-cdc/pom.xml b/paimon-flink/paimon-flink-cdc/pom.xml
@@ -34,7 +34,7 @@ under the License.
     <name>Paimon : Flink : CDC</name>
 
     <properties>
-        <flink.version>1.18.1</flink.version>
+        <flink.version>1.20.0</flink.version>
         <flink.cdc.version>3.1.1</flink.cdc.version>
         <flink.mongodb.cdc.version>3.1.1</flink.mongodb.cdc.version>
         <avro.version>1.11.4</avro.version>
@@ -43,7 +43,7 @@ under the License.
         <mongodb.testcontainers.version>1.19.1</mongodb.testcontainers.version>
         <flink.connector.pulsar.version>4.0.0-1.17</flink.connector.pulsar.version>
         <confluent.platform.version>7.5.0</confluent.platform.version>
-        <flink.connector.kafka.version>3.0.1-1.18</flink.connector.kafka.version>
+        <flink.connector.kafka.version>3.3.0-1.20</flink.connector.kafka.version>
     </properties>
 
     <repositories>
@@ -167,6 +167,13 @@ under the License.
 
         <!-- test dependencies -->
 
+        <dependency>
+            <groupId>commons-codec</groupId>
+            <artifactId>commons-codec</artifactId>
+            <version>1.9</version>
+            <scope>test</scope>
+        </dependency>
+
         <dependency>
             <groupId>org.apache.paimon</groupId>
             <artifactId>paimon-common</artifactId>

diff --git a/...k-cdc/src/main/java/org/apache/flink/streaming/runtime/streamrecord/RecordAttributes.java b/...k-cdc/src/main/java/org/apache/flink/streaming/runtime/streamrecord/RecordAttributes.java
diff --git a/...imon-flink-cdc/src/main/java/org/apache/flink/table/catalog/CatalogMaterializedTable.java b/...imon-flink-cdc/src/main/java/org/apache/flink/table/catalog/CatalogMaterializedTable.java