This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from daa8197bdd [Fix][Transform-V2] Fail CAST to BIGINT on out-of-range
numeric input (#12899)
add 56b063c1d8 [Fix][Connector-V2] Exclude columns not published by
pgoutput from the Postgres-CDC schema (#12561)
No new revisions were added by this update.
Summary of changes:
docs/en/connectors/source/PostgreSQL-CDC.md | 10 +
.../introduction/concepts/incompatible-changes.md | 6 +
docs/zh/connectors/source/PostgreSQL-CDC.md | 10 +
.../introduction/concepts/incompatible-changes.md | 6 +
.../source/PostgresIncrementalSourceFactory.java | 20 +
.../postgres/utils/PostgresPublishedColumns.java | 312 +++++++++++++++
.../config/PostgresSourceConfigFactoryTest.java | 3 +
.../source/PostgresIncrementalSourceTest.java | 82 ++++
.../utils/PostgresPublishedColumnsTest.java | 351 +++++++++++++++++
.../cdc/postgres/PostgresCDCGeneratedColumnIT.java | 430 +++++++++++++++++++++
... postgrescdc_to_postgres_with_column_list.conf} | 44 +--
...cdc_to_postgres_with_existing_publication.conf} | 33 +-
...grescdc_to_postgres_with_generated_column.conf} | 28 +-
13 files changed, 1282 insertions(+), 53 deletions(-)
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/utils/PostgresPublishedColumns.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/utils/PostgresPublishedColumnsTest.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-postgres-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/PostgresCDCGeneratedColumnIT.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-postgres-e2e/src/test/resources/{pgcdc_to_pg_with_multi_table_mode_one_table.conf
=> postgrescdc_to_postgres_with_column_list.conf} (56%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-postgres-e2e/src/test/resources/{postgrescdc_to_postgres_committed_offset.conf
=> postgrescdc_to_postgres_with_existing_publication.conf} (60%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-postgres-e2e/src/test/resources/{postgrescdc_to_postgres_snapshot_only.conf
=> postgrescdc_to_postgres_with_generated_column.conf} (63%)
