fix postgres includeSchemaChanges

yunfengzhou-hub · Nov 24, 2024 · f2a927a · f2a927a
1 parent f803ede
commit f2a927a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/paimon-flink/paimon-flink-cdc/pom.xml b/paimon-flink/paimon-flink-cdc/pom.xml
@@ -35,8 +35,8 @@ under the License.
 
     <properties>
         <flink.version>2.0-preview1</flink.version>
-        <flink.cdc.version>3.1.1</flink.cdc.version>
-        <flink.mongodb.cdc.version>3.1.1</flink.mongodb.cdc.version>
+        <flink.cdc.version>3.2.0</flink.cdc.version>
+        <flink.mongodb.cdc.version>3.2.0</flink.mongodb.cdc.version>
         <avro.version>1.11.4</avro.version>
         <geometry.version>2.2.0</geometry.version>
         <json-path.version>2.9.0</json-path.version>

diff --git a/...nk-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresActionUtils.java b/...nk-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresActionUtils.java
@@ -186,7 +186,7 @@ public static JdbcIncrementalSource<CdcSourceRecord> buildPostgresSource(
         customConverterConfigs.put(JsonConverterConfig.DECIMAL_FORMAT_CONFIG, "numeric");
         CdcDebeziumDeserializationSchema schema =
                 new CdcDebeziumDeserializationSchema(true, customConverterConfigs);
-        return sourceBuilder.deserializer(schema).includeSchemaChanges(true).build();
+        return sourceBuilder.deserializer(schema).build();
     }
 
     public static void registerJdbcDriver() {