alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-3838 Do not reset trx isolation when using minimal_percona

Browse Source
This commit is contained in:
Chris Cranford 2021-08-09 10:59:11 -04:00 committed by Gunnar Morling
parent c0fb820d97
commit 060420b0bc
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlSnapshotChangeEventSource.java
View File

@ -194,10 +194,12 @@ protected void lockTablesForSchemaSnapshot(ChangeEventSourceContext sourceContex
// Continue anyway, since RDS (among others) don't allow setting a global lock
assert !isGloballyLocked();
}
if (!connectorConfig.getSnapshotLockingMode().equals(MySqlConnectorConfig.SnapshotLockingMode.MINIMAL_PERCONA)) {
// FLUSH TABLES resets TX and isolation level
connection.executeWithoutCommitting("SET TRANSACTION ISOLATION LEVEL REPEATABLE READ");
}
}
}
@Override
protected void releaseSchemaSnapshotLocks(RelationalSnapshotContext<MySqlPartition, MySqlOffsetContext> snapshotContext)