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)),