From 1722712374bdb68f40f65be777e345a3cadf358b Mon Sep 17 00:00:00 2001 From: Xin Gong Date: Fri, 8 Nov 2024 13:46:50 +0800 Subject: [PATCH] [FLINK-36247][cdc-connector][mysql] Fix potential transaction leak during MySQL snapshot phase (#3602) --- .../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 64787eb9ac7..6e621e0a5fb 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 static String quote(TableId tableId) { 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;