Skip to content

Commit 66a1435

Browse files
author
tchivs
committed
[FLINK-38188][pipeline-connector][postgres] add a test coverage to e2e PostgresE2eITCase to cover the bug.(apache#4075)
1 parent bb1d150 commit 66a1435

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/PostgresE2eITCase.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ void testSyncWholeDatabase() throws Exception {
111111
+ " port: %d\n"
112112
+ " username: %s\n"
113113
+ " password: %s\n"
114-
+ " tables: %s.inventory.\\.*\n"
114+
+ " tables: %s.inventory.products,%s.inventory.customers\n"
115115
+ " slot.name: %s\n"
116116
+ " scan.startup.mode: initial\n"
117117
+ " server-time-zone: UTC\n"
@@ -127,6 +127,7 @@ void testSyncWholeDatabase() throws Exception {
127127
POSTGRES_TEST_USER,
128128
POSTGRES_TEST_PASSWORD,
129129
postgresInventoryDatabase.getDatabaseName(),
130+
postgresInventoryDatabase.getDatabaseName(),
130131
slotName,
131132
parallelism);
132133
Path postgresCdcJar = TestUtils.getResource("postgres-cdc-pipeline-connector.jar");

0 commit comments

Comments
 (0)