This is an automated email from the ASF dual-hosted git repository.
yuxiqian pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
from b18f95e67 [FLINK-39777][common] Add TableId partitioning strategy
configuration (#4423)
add be5399f72 [FLINK-38647][connect/postgres] Improve error message when
REPLICA IDENTITY FULL is not configured (#4439)
No new revisions were added by this update.
Summary of changes:
.../postgres/source/PostgresEventDeserializer.java | 15 ++++
.../source/PostgresEventDeserializerTest.java | 53 +++++++++++++++
.../postgres/source/PostgresPipelineITCase.java | 79 ++++++++++++++++++++++
.../event/DebeziumEventDeserializationSchema.java | 3 +-
4 files changed, 149 insertions(+), 1 deletion(-)
create mode 100644
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresEventDeserializerTest.java
