From 89ef42fed84010b366b1bc0706c926429139f14d Mon Sep 17 00:00:00 2001
From: wudi <676366545@qq.com>
Date: Tue, 3 Dec 2024 10:02:02 +0800
Subject: [PATCH 1/2] update cdc version

---
 flink-doris-connector/pom.xml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-doris-connector/pom.xml b/flink-doris-connector/pom.xml
index 775242b05..4b51a089b 100644
--- a/flink-doris-connector/pom.xml
+++ b/flink-doris-connector/pom.xml
@@ -70,7 +70,7 @@ under the License.
         <revision>24.0.0-SNAPSHOT</revision>
         <flink.version>1.18.0</flink.version>
         <flink.major.version>1.18</flink.major.version>
-        <flink.sql.cdc.version>3.1.1</flink.sql.cdc.version>
+        <flink.sql.cdc.version>3.2.1</flink.sql.cdc.version>
         <flink.python.id>flink-python</flink.python.id>
         <libthrift.version>0.16.0</libthrift.version>
         <maven-compiler-plugin.version>3.10.1</maven-compiler-plugin.version>

From a520d23df252fe89ee593116802bb86239830e9d Mon Sep 17 00:00:00 2001
From: wudi <676366545@qq.com>
Date: Tue, 3 Dec 2024 10:19:54 +0800
Subject: [PATCH 2/2] remove unsupport code

---
 .../doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java     | 1 -
 1 file changed, 1 deletion(-)

diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java
index 15fc632b4..41aca26cd 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java
+++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java
@@ -191,7 +191,6 @@ public DataStreamSource<String> buildCdcSource(StreamExecutionEnvironment env) {
                             .deserializer(schema)
                             .slotName(slotName)
                             .decodingPluginName(config.get(DECODING_PLUGIN_NAME))
-                            .includeSchemaChanges(true)
                             .debeziumProperties(debeziumProperties)
                             .startupOptions(startupOptions)
                             .splitSize(config.get(SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE))