diff --git a/java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/JDBCSink.java b/java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/JDBCSink.java index 64b2b7602e3b9..399a312758e3b 100644 --- a/java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/JDBCSink.java +++ b/java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/JDBCSink.java @@ -89,6 +89,8 @@ public JDBCSink(JDBCSinkConfig config, TableSchema tableSchema) { "JDBC connection: autoCommit = {}, trxn = {}", conn.getAutoCommit(), conn.getTransactionIsolation()); + // Commit the `getTransactionIsolation` + conn.commit(); jdbcStatements = new JdbcStatements(conn); } catch (SQLException e) {