Update PostgresSourceExampleTest.java

apache · Jul 16, 2024 · 3da71ed · 3da71ed
1 parent 19a3c7d
commit 3da71ed
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/.../test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceExampleTest.java b/.../test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceExampleTest.java
@@ -108,7 +108,6 @@ public void testConsumingScanEvents() throws Exception {
                         .slotName(SLOT_NAME)
                         .decodingPluginName(PLUGIN_NAME)
                         .deserializer(deserializer)
-                        .includeSchemaChanges(true) // output the schema changes as well
                         .splitSize(2)
                         .build();
 
@@ -153,7 +152,6 @@ public void testConsumingAllEvents() throws Exception {
                         .slotName(SLOT_NAME)
                         .decodingPluginName(PLUGIN_NAME)
                         .deserializer(buildRowDataDebeziumDeserializeSchema(dataType))
-                        .includeSchemaChanges(true) // output the schema changes as well
                         .splitSize(2)
                         .debeziumProperties(debeziumProps)
                         .build();