[hotfix][docs][postgres] Remove unsupported erroneous example code

This closes #3464
apache · Jul 16, 2024 · a2539f5 · a2539f5
1 parent 2d1eb0a
commit a2539f5
Show file tree

Hide file tree

Showing 4 changed files with 0 additions and 10 deletions.
diff --git a/docs/content.zh/docs/connectors/flink-sources/postgres-cdc.md b/docs/content.zh/docs/connectors/flink-sources/postgres-cdc.md
@@ -470,7 +470,6 @@ public class PostgresParallelSourceExample {
                         .slotName("flink")
                         .decodingPluginName("decoderbufs") // use pgoutput for PostgreSQL 10+
                         .deserializer(deserializer)
-                        .includeSchemaChanges(true) // output the schema changes as well
                         .splitSize(2) // the split size of each snapshot split
                         .build();
 

diff --git a/docs/content/docs/connectors/flink-sources/postgres-cdc.md b/docs/content/docs/connectors/flink-sources/postgres-cdc.md
@@ -481,7 +481,6 @@ public class PostgresParallelSourceExample {
                         .slotName("flink")
                         .decodingPluginName("decoderbufs") // use pgoutput for PostgreSQL 10+
                         .deserializer(deserializer)
-                        .includeSchemaChanges(true) // output the schema changes as well
                         .splitSize(2) // the split size of each snapshot split
                         .build();
 

diff --git a/.../src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceBuilder.java b/.../src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceBuilder.java
@@ -199,12 +199,6 @@ public PostgresSourceBuilder<T> connectionPoolSize(int connectionPoolSize) {
         return this;
     }
 
-    /** Whether the {@link PostgresIncrementalSource} should output the schema changes or not. */
-    public PostgresSourceBuilder<T> includeSchemaChanges(boolean includeSchemaChanges) {
-        this.configFactory.includeSchemaChanges(includeSchemaChanges);
-        return this;
-    }
-
     /** Specifies the startup options. */
     public PostgresSourceBuilder<T> startupOptions(StartupOptions startupOptions) {
         this.configFactory.startupOptions(startupOptions);

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