fix(connector): idle transaction SHOW TRANSACTION ISOLATION LEVEL w…

…hen no sinked data (#16847)
risingwavelabs · May 21, 2024 · e8a3e33 · e8a3e33
1 parent 7bb5480
commit e8a3e33
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/.../connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/JDBCSink.java b/.../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) {