Skip to content

Commit d5f1b9a

Browse files
authored
[FLINK-36247][cdc-connector][mysql] Fix potential transaction leak during MySQL snapshot phase (#3602)
1 parent 5d58769 commit d5f1b9a

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/StatementUtils.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -235,7 +235,6 @@ public static String quote(TableId tableId) {
235235
private static PreparedStatement initStatement(JdbcConnection jdbc, String sql, int fetchSize)
236236
throws SQLException {
237237
final Connection connection = jdbc.connection();
238-
connection.setAutoCommit(false);
239238
final PreparedStatement statement = connection.prepareStatement(sql);
240239
statement.setFetchSize(fetchSize);
241240
return statement;

0 commit comments

Comments
 (0)