(flink-cdc) branch master updated: [FLINK-38546][cdc/mysql] Improve error message for table discovery failure due to MySQL permission (#4158)

[kunni]

This is an automated email from the ASF dual-hosted git repository.

kunni pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


The following commit(s) were added to refs/heads/master by this push:
     new a62bae71f [FLINK-38546][cdc/mysql] Improve error message for table 
discovery failure due to MySQL permission (#4158)
a62bae71f is described below

commit a62bae71ff36619f88ba7b4199e0c6013181b91e
Author: Junbo Wang <beryllw...@gmail.com>
AuthorDate: Thu Oct 23 16:27:48 2025 +0800

    [FLINK-38546][cdc/mysql] Improve error message for table discovery failure 
due to MySQL permission (#4158)
---
 .../org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtils.java   | 2 +-
 .../flink/cdc/connectors/mysql/source/utils/TableDiscoveryUtils.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtils.java
 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtils.java
index 7ca60be5b..4e512a81c 100644
--- 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtils.java
+++ 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtils.java
@@ -202,7 +202,7 @@ public class DebeziumUtils {
         if (capturedTableIds.isEmpty()) {
             throw new IllegalArgumentException(
                     String.format(
-                            "Can't find any matched tables, please check your 
configured database-name: %s and table-name: %s",
+                            "No matched tables found. Please verify:\n1) The 
configured database(s) [%s] and table(s) [%s] exist;\n2) The MySQL user has 
sufficient permissions to access them.",
                             sourceConfig.getDatabaseList(), 
sourceConfig.getTableList()));
         }
         return capturedTableIds;
diff --git 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/TableDiscoveryUtils.java
 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/TableDiscoveryUtils.java
index dedeab2dd..725200531 100644
--- 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/TableDiscoveryUtils.java
+++ 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/TableDiscoveryUtils.java
@@ -147,7 +147,7 @@ public class TableDiscoveryUtils {
         if (capturedTableIds.isEmpty()) {
             throw new IllegalArgumentException(
                     String.format(
-                            "Can't find any matched tables, please check your 
configured database-name: %s and table-name: %s",
+                            "No matched tables found. Please verify:\n1) The 
configured database(s) [%s] and table(s) [%s] exist;\n2) The MySQL user has 
sufficient permissions to access them.",
                             sourceConfig.getDatabaseList(), 
sourceConfig.getTableList()));
         }