This is an automated email from the ASF dual-hosted git repository.
jiabaosun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new a7cb46f76 [FLINK-35274][cdc-connector][db2] Fix occasional failure
issue with Flink CDC Db2 UT
a7cb46f76 is described below
commit a7cb46f7621568486a069a7ae01a7b86ebb0a801
Author: Xin Gong <genzhedangd...@gmail.com>
AuthorDate: Mon May 6 13:54:08 2024 +0800
[FLINK-35274][cdc-connector][db2] Fix occasional failure issue with Flink
CDC Db2 UT
---
.../src/main/java/io/debezium/connector/db2/Db2Connection.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2/Db2Connection.java
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2/Db2Connection.java
index a916808bf..616fd7c95 100644
---
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2/Db2Connection.java
+++
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2/Db2Connection.java
@@ -323,7 +323,8 @@ public class Db2Connection extends JdbcConnection {
*/
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)),
