From 48122727f96aebce6b1ef4e03645121f0dcb1492 Mon Sep 17 00:00:00 2001 From: liuliu Date: Tue, 8 Aug 2023 15:09:32 +0800 Subject: [PATCH] [minor][mysql] database-filter remove unnecessary logs --- .../connectors/mysql/source/utils/TableDiscoveryUtils.java | 5 ----- 1 file changed, 5 deletions(-) diff --git a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/utils/TableDiscoveryUtils.java b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/utils/TableDiscoveryUtils.java index 6012dea1577..a656b5e0f2e 100644 --- a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/utils/TableDiscoveryUtils.java +++ b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/utils/TableDiscoveryUtils.java @@ -60,11 +60,6 @@ public static List listTables(JdbcConnection jdbc, RelationalTableFilte String databaseName = rs.getString(1); if (tableFilters.databaseFilter().test(databaseName)) { databaseNames.add(databaseName); - LOG.info( - "\t including database '{}' for further processing", - databaseName); - } else { - LOG.info("\t '{}' is filtered out of database capturing", databaseName); } } });