apache/seatunnel · error · DebeziumException

Unexpected error while connecting to MySQL and looking at pr

Error message

Unexpected error while connecting to MySQL and looking at privileges for current user: 

What it means

userHasPrivileges queries MySQL's SHOW GRANTS (or equivalent) for the current user and wraps any SQLException into this DebeziumException. It indicates the privilege check itself failed at the JDBC/SQL level, not that the user lacks privileges.

Source

Thrown at seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/io/debezium/connector/mysql/MySqlConnection.java:379

            return queryAndMap(
                    "SHOW GRANTS FOR CURRENT_USER",
                    rs -> {
                        while (rs.next()) {
                            String grants = rs.getString(1);
                            LOGGER.debug(grants);
                            if (grants == null) {
                                return false;
                            }
                            grants = grants.toUpperCase();
                            if (grants.contains("ALL")
                                    || grants.contains(grantName.toUpperCase())) {
                                return true;
                            }
                        }
                        return false;
                    });
        } catch (SQLException e) {
            throw new DebeziumException(
                    "Unexpected error while connecting to MySQL and looking at privileges for current user: ",
                    e);
        }
    }

    /**
     * Determine the earliest binlog filename that is still available in the server.
     *
     * @return the name of the earliest binlog filename, or null if there are none.
     */
    public String earliestBinlogFilename() {
        // Accumulate the available binlog filenames ...
        List<String> logNames = new ArrayList<>();
        try {
            LOGGER.info("Checking all known binlogs from MySQL");
            query(
                    "SHOW BINARY LOGS",
                    rs -> {

View on GitHub (pinned to cf67b549a7)

Solutions

1. Verify the MySQL connection works with the configured credentials
2. Ensure the CDC user can execute SHOW GRANTS FOR CURRENT_USER
3. Inspect the cause SQLException and MySQL error log
4. Fix network/firewall/TLS issues and retry

try (Statement s = conn.createStatement()) { s.executeQuery("SHOW GRANTS FOR CURRENT_USER()"); }

catch (DebeziumException e) { logger.error("Privilege check query failed", e.getCause()); /* fix connectivity or grants, then retry */ }

When it happens

Trigger: SQLException while executing the privileges query inside userHasPrivileges — connection failure, permissions problem running SHOW GRANTS, or server error.

Common situations: Connector startup validation against an unreachable or overloaded MySQL; restricted user account that cannot even execute SHOW GRANTS; network/TLS interruption.

Understand the failure class

Background: Database query failed: Internal Server Error 500s wrapping SQL, Prisma, and connection failures — what to check first — this error's family across 16 libraries.

Related errors

• Unexpected error while connecting to MySQL and looking at pr
• Error reading MySQL variables:
• Unexpected error while connecting to MySQL and looking at GT
• Unexpected error while connecting to MySQL and looking for b
• Unexpected error while connecting to MySQL and looking at BI

AI-assisted analysis of apache/seatunnel@cf67b549a7 (2026-09-10). Data as JSON: /api/errors/214cfd12d8193d55. Report an issue: GitHub.