Skip to content

Commit aa6de9e

Browse files
ruanhang1993gong
andauthored
[FLINK-36247][cdc-connector][mysql] Fix potential transaction leak during MySQL snapshot phase (#3602) (#3699)
Co-authored-by: Xin Gong <genzhedangdang@gmail.com>
1 parent 722eb2e commit aa6de9e

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)