From 883c2393cab8ea406063bb56ac474d5ee59ebd86 Mon Sep 17 00:00:00 2001 From: zhangjun Date: Thu, 17 Aug 2023 21:17:51 +0800 Subject: [PATCH] only sync table --- .../paimon/flink/action/cdc/mysql/MySqlActionUtils.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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 =