Skip to content

Commit a2539f5

Browse files
authored
[hotfix][docs][postgres] Remove unsupported erroneous example code
This closes #3464
1 parent 2d1eb0a commit a2539f5

File tree

4 files changed

+0
-10
lines changed

4 files changed

+0
-10
lines changed

docs/content.zh/docs/connectors/flink-sources/postgres-cdc.md

-1
Original file line numberDiff line numberDiff line change
@@ -470,7 +470,6 @@ public class PostgresParallelSourceExample {
470470
.slotName("flink")
471471
.decodingPluginName("decoderbufs") // use pgoutput for PostgreSQL 10+
472472
.deserializer(deserializer)
473-
.includeSchemaChanges(true) // output the schema changes as well
474473
.splitSize(2) // the split size of each snapshot split
475474
.build();
476475

docs/content/docs/connectors/flink-sources/postgres-cdc.md

-1
Original file line numberDiff line numberDiff line change
@@ -481,7 +481,6 @@ public class PostgresParallelSourceExample {
481481
.slotName("flink")
482482
.decodingPluginName("decoderbufs") // use pgoutput for PostgreSQL 10+
483483
.deserializer(deserializer)
484-
.includeSchemaChanges(true) // output the schema changes as well
485484
.splitSize(2) // the split size of each snapshot split
486485
.build();
487486

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceBuilder.java

-6
Original file line numberDiff line numberDiff line change
@@ -199,12 +199,6 @@ public PostgresSourceBuilder<T> connectionPoolSize(int connectionPoolSize) {
199199
return this;
200200
}
201201

202-
/** Whether the {@link PostgresIncrementalSource} should output the schema changes or not. */
203-
public PostgresSourceBuilder<T> includeSchemaChanges(boolean includeSchemaChanges) {
204-
this.configFactory.includeSchemaChanges(includeSchemaChanges);
205-
return this;
206-
}
207-
208202
/** Specifies the startup options. */
209203
public PostgresSourceBuilder<T> startupOptions(StartupOptions startupOptions) {
210204
this.configFactory.startupOptions(startupOptions);

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceExampleTest.java

-2
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,6 @@ public void testConsumingScanEvents() throws Exception {
108108
.slotName(SLOT_NAME)
109109
.decodingPluginName(PLUGIN_NAME)
110110
.deserializer(deserializer)
111-
.includeSchemaChanges(true) // output the schema changes as well
112111
.splitSize(2)
113112
.build();
114113

@@ -153,7 +152,6 @@ public void testConsumingAllEvents() throws Exception {
153152
.slotName(SLOT_NAME)
154153
.decodingPluginName(PLUGIN_NAME)
155154
.deserializer(buildRowDataDebeziumDeserializeSchema(dataType))
156-
.includeSchemaChanges(true) // output the schema changes as well
157155
.splitSize(2)
158156
.debeziumProperties(debeziumProps)
159157
.build();

0 commit comments

Comments
 (0)