diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java
index 978d2eaa80d10..8834c2ab99a36 100644
--- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java
+++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java
@@ -119,7 +119,9 @@ static MySqlSchemasInfo getMySqlTableInfos(
                     String databaseName = schemas.getString("TABLE_CAT");
                     Matcher databaseMatcher = databasePattern.matcher(databaseName);
                     if (databaseMatcher.matches()) {
-                        try (ResultSet tables = metaData.getTables(databaseName, null, "%", null)) {
+                        try (ResultSet tables =
+                                metaData.getTables(
+                                        databaseName, null, "%", new String[] {"TABLE"})) {
                             while (tables.next()) {
                                 String tableName = tables.getString("TABLE_NAME");
                                 MySqlSchema mySqlSchema =