This is an automated email from the ASF dual-hosted git repository.
jiabaosun pushed a commit to branch release-3.1
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/release-3.1 by this push:
new d556f2947 [FLINK-35274][cdc-connector][db2] Fix occasional failure
issue with Flink CDC Db2 UT
d556f2947 is described below
commit d556f29475a52234a98bcc65db959483a10beb52
Author: Xin Gong <[email protected]>
AuthorDate: Mon May 6 13:54:32 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)),
