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] 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 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))