Merge branch 'master' into improve-httpclient

JNSimba · Dec 4, 2024 · c080ae8 · c080ae8
2 parents c7ec42c + 9cabe21
commit c080ae8
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git 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>

diff --git a/...nnector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java b/...nnector/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))