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