(flink-cdc) branch master updated: [FLINK-36247][cdc-connector][mysql] Fix potential transaction leak during MySQL snapshot phase (#3602)

[ru...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ruanhang1993 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


The following commit(s) were added to refs/heads/master by this push:
     new d5f1b9ace [FLINK-36247][cdc-connector][mysql] Fix potential transaction leak during MySQL snapshot phase (#3602)
d5f1b9ace is described below

commit d5f1b9ace82f91bbf16aa8ec56a29b7fb0456c0b
Author: Xin Gong <ge...@gmail.com>
AuthorDate: Fri Nov 8 13:46:50 2024 +0800

    [FLINK-36247][cdc-connector][mysql] Fix potential transaction leak during MySQL snapshot phase (#3602)
---
 .../apache/flink/cdc/connectors/mysql/source/utils/StatementUtils.java   | 1 -
 1 file changed, 1 deletion(-)

diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/StatementUtils.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/StatementUtils.java
index 64787eb9a..6e621e0a5 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/StatementUtils.java
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/StatementUtils.java
@@ -235,7 +235,6 @@ public class StatementUtils {
     private static PreparedStatement initStatement(JdbcConnection jdbc, String sql, int fetchSize)
             throws SQLException {
         final Connection connection = jdbc.connection();
-        connection.setAutoCommit(false);
         final PreparedStatement statement = connection.prepareStatement(sql);
         statement.setFetchSize(fetchSize);
         return statement;