loserwang1024 commented on code in PR #4002:
URL: https://github.com/apache/flink-cdc/pull/4002#discussion_r2057943076
##########
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLConnectorITCase.java:
##########
@@ -277,6 +277,111 @@ public void testStartupFromLatestOffset() throws
Exception {
result.getJobClient().get().cancel().get();
}
+ @Test
+ public void testStartupFromCommittedOffset() throws Exception {
+ if (!parallelismSnapshot) {
+ return;
+ }
+ initializePostgresTable(POSTGRES_CONTAINER, "inventory");
+
+ String sourceDDL =
+ String.format(
+ "CREATE TABLE debezium_source ("
+ + " id INT NOT NULL,"
+ + " name STRING,"
+ + " description STRING,"
+ + " weight DECIMAL(10,3),"
+ + " PRIMARY KEY (id) NOT ENFORCED"
+ + ") WITH ("
+ + " 'connector' = 'postgres-cdc',"
+ + " 'hostname' = '%s',"
+ + " 'port' = '%s',"
+ + " 'username' = '%s',"
+ + " 'password' = '%s',"
+ + " 'database-name' = '%s',"
+ + " 'schema-name' = '%s',"
+ + " 'table-name' = '%s',"
+ + " 'scan.incremental.snapshot.enabled' =
'%s',"
+ + " 'slot.name' = '%s',"
Review Comment:
please add " 'decoding.plugin.name' = 'pgoutput' here, because we have
upgrade image to official pg14(which not nested with decoderbuf
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
