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

DBZ-7308 Fix MySQL tests

Browse Source
This commit is contained in:
mfvitale 2024-03-20 12:22:16 +01:00 committed by Jiri Pechanec
parent c7a28021a6
commit 662a0518ac
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlConnectorIT.java
View File

@ -296,7 +296,7 @@ public void shouldValidateLockingModeNoneWithValidSnapshotModeConfiguration() {
Config result = connector.validate(config.asMap()); Config result = connector.validate(config.asMap());
assertNoConfigurationErrors(result, MySqlConnectorConfig.SNAPSHOT_LOCKING_MODE); assertNoConfigurationErrors(result, MySqlConnectorConfig.SNAPSHOT_LOCKING_MODE);
assertThat(new MySqlConnectorConfig(config).getSnapshotLockingMode()).isEqualTo(SnapshotLockingMode.NONE); assertThat(new MySqlConnectorConfig(config).getSnapshotLockingMode().get()).isEqualTo(SnapshotLockingMode.NONE);
} }
} }

8
debezium-core/src/main/java/io/debezium/snapshot/lock/NoLockingSupport.java
View File

@ -16,13 +16,13 @@ public class NoLockingSupport implements SnapshotLock {
public static final String NO_LOCKING_SUPPORT = "no_locking_support"; public static final String NO_LOCKING_SUPPORT = "no_locking_support";
@Override @Override
public void configure(Map<String, ?> properties) { public String name() {
return NO_LOCKING_SUPPORT;
} }
@Override @Override
public String name() { public void configure(Map<String, ?> properties) {
return NO_LOCKING_SUPPORT;
} }
@Override @Override