only sync table

apache · Aug 17, 2023 · 883c239 · 883c239
1 parent 58cd5a5
commit 883c239
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java b/...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 =