This is an automated email from the ASF dual-hosted git repository.
leonard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new a2539f5cf [hotfix][docs][postgres] Remove unsupported erroneous
example code
a2539f5cf is described below
commit a2539f5cfa11544d7f09af6978d2365e67dec783
Author: skylines <[email protected]>
AuthorDate: Tue Jul 16 18:50:57 2024 +0800
[hotfix][docs][postgres] Remove unsupported erroneous example code
This closes #3464
---
docs/content.zh/docs/connectors/flink-sources/postgres-cdc.md | 1 -
docs/content/docs/connectors/flink-sources/postgres-cdc.md | 1 -
.../flink/cdc/connectors/postgres/source/PostgresSourceBuilder.java | 6 ------
.../cdc/connectors/postgres/source/PostgresSourceExampleTest.java | 2 --
4 files changed, 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
index 69d47eb57..68a09c889 100644
--- 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
index 16c2d84b4..ea21ed7a3 100644
--- 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/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceBuilder.java
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceBuilder.java
index ee991a70f..af220061a 100644
---
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceBuilder.java
+++
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceBuilder.java
@@ -199,12 +199,6 @@ public class PostgresSourceBuilder<T> {
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/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceExampleTest.java
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceExampleTest.java
index f6f2b45d9..77165333b 100644
---
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceExampleTest.java
+++
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceExampleTest.java
@@ -108,7 +108,6 @@ public class PostgresSourceExampleTest extends
PostgresTestBase {
.slotName(SLOT_NAME)
.decodingPluginName(PLUGIN_NAME)
.deserializer(deserializer)
- .includeSchemaChanges(true) // output the schema
changes as well
.splitSize(2)
.build();
@@ -153,7 +152,6 @@ public class PostgresSourceExampleTest extends
PostgresTestBase {
.slotName(SLOT_NAME)
.decodingPluginName(PLUGIN_NAME)
.deserializer(buildRowDataDebeziumDeserializeSchema(dataType))
- .includeSchemaChanges(true) // output the schema
changes as well
.splitSize(2)
.debeziumProperties(debeziumProps)
.build();
