[FLINK-35274][cdc-connector][db2] Fix occasional failure issue with F…

…link CDC Db2 UT
apache · May 6, 2024 · d556f29 · d556f29
1 parent 71dfad2
commit d556f29
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...ectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2/Db2Connection.java b/...ectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2/Db2Connection.java
@@ -323,7 +323,8 @@ public Set<Db2ChangeTable> listOfChangeTables() throws SQLException {
                          */
                         changeTables.add(
                                 new Db2ChangeTable(
-                                        new TableId("", rs.getString(1), rs.getString(2)),
+                                        new TableId(
+                                                realDatabaseName, rs.getString(1), rs.getString(2)),
                                         rs.getString(4),
                                         rs.getInt(9),
                                         Lsn.valueOf(rs.getBytes(5)),