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 a916808bfae..616fd7c951d 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 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)),