| commit | 439b736029d8627a1247f743ae4c846a6e9fd6b2 | [log] [tgz] |
|---|---|---|
| author | dy102 <132787602+dybyte@users.noreply.github.com> | Fri Nov 21 17:30:45 2025 +0900 |
| committer | GitHub <noreply@github.com> | Fri Nov 21 16:30:45 2025 +0800 |
| tree | ef53e43e749c70ed0fa338ff7df498f44c75a6c3 | |
| parent | a17512f11350de700405bcc8e88598869a894738 [diff] |
[Fix][Connector-V2] Ignore JdbcConnectorException on JDBC statement close (#9942)
diff --git a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSinkOptions.java b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSinkOptions.java index 0c51108..eacd23c 100644 --- a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSinkOptions.java +++ b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSinkOptions.java
@@ -67,7 +67,7 @@ .withDescription("auto commit"); public static final Option<Integer> MAX_RETRIES = - Options.key("max_retries").intType().defaultValue(0).withDescription("max_retired"); + Options.key("max_retries").intType().defaultValue(0).withDescription("max_retries"); public static final Option<String> XA_DATA_SOURCE_CLASS_NAME = Options.key("xa_data_source_class_name")
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 1097c2d..7c184c9 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
@@ -194,7 +194,7 @@ if (jdbcStatementExecutor != null) { jdbcStatementExecutor.closeStatements(); } - } catch (SQLException e) { + } catch (SQLException | JdbcConnectorException e) { LOG.warn("Close JDBC writer failed.", e); } } @@ -205,7 +205,7 @@ public void updateExecutor(boolean reconnect) throws SQLException, ClassNotFoundException { try { jdbcStatementExecutor.closeStatements(); - } catch (SQLException e) { + } catch (SQLException | JdbcConnectorException e) { if (!reconnect) { throw e; }