DBZ-7308 tableLockingStatement from SnapshotLock interface now takes …

…just one table in input
debezium · Mar 18, 2024 · 2c1a7f1 · 2c1a7f1
1 parent 942ab80
commit 2c1a7f1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/io/debezium/connector/db2/Db2SnapshotChangeEventSource.java b/src/main/java/io/debezium/connector/db2/Db2SnapshotChangeEventSource.java
@@ -90,7 +90,7 @@ else if (connectorConfig.getSnapshotIsolationMode() == SnapshotIsolationMode.EXC
                     }
 
                     Optional<String> lockingStatement = snapshotterService.getSnapshotLock().tableLockingStatement(connectorConfig.snapshotLockTimeout(),
-                            Set.of(quoteTableName(tableId)));
+                            quoteTableName(tableId));
 
                     if (lockingStatement.isPresent()) {
                         LOGGER.info("Locking table {}", tableId);