remove unsupport code

JNSimba · Dec 3, 2024 · a520d23 · a520d23
1 parent 89ef42f
commit a520d23
Showing 1 changed file with 0 additions and 1 deletion.
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))