diff --git a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormat.java b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormat.java index c26e2d9f70f..ee3c4a7a68b 100644 --- a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormat.java +++ b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormat.java @@ -245,7 +245,7 @@ public void updateExecutor(boolean reconnect) throws SQLException, ClassNotFound if (!reconnect) { throw e; } - LOG.info("Close JDBC statement failed on reconnect.", e); + LOG.error("Close JDBC statement failed on reconnect.", e); } jdbcStatementExecutor.prepareStatements( reconnect