This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 9cabe218 [Improve](cdc) update cdc version to 3.2.1 (#521)
9cabe218 is described below
commit 9cabe21873e8572d7c5fabffe863976934698c7d
Author: wudi <[email protected]>
AuthorDate: Wed Dec 4 10:13:50 2024 +0800
[Improve](cdc) update cdc version to 3.2.1 (#521)
---
flink-doris-connector/pom.xml | 2 +-
.../org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java | 1 -
2 files changed, 1 insertion(+), 2 deletions(-)
diff --git a/flink-doris-connector/pom.xml b/flink-doris-connector/pom.xml
index 775242b0..4b51a089 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>
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 15fc632b..41aca26c 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 class PostgresDatabaseSync extends DatabaseSync {
.deserializer(schema)
.slotName(slotName)
.decodingPluginName(config.get(DECODING_PLUGIN_NAME))
- .includeSchemaChanges(true)
.debeziumProperties(debeziumProperties)
.startupOptions(startupOptions)
.splitSize(config.get(SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE))
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
