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

DBZ-8054 Rework key sort to fix Infinispan test failures

Browse Source
This commit is contained in:
Chris Cranford 2024-07-30 14:00:24 -04:00 committed by Chris Cranford
parent 41a817828d
commit 28ca70c396
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractTransactionCachingLogMinerEventProcessor.java
View File

@ -13,7 +13,10 @@
import java.util.Iterator;
import java.util.List;
import java.util.Optional;
import java.util.TreeMap;
import java.util.function.Function;
import java.util.function.Supplier;
import java.util.stream.Collectors;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@ -160,8 +163,16 @@ protected List<String> getTransactionKeysWithPrefix(String prefix) {
return getEventCache()
.streamAndReturn(stream -> stream.map(LogMinerCache.Entry::getKey)
.filter(k -> k.startsWith(prefix))
.sorted(EventKeySortComparator.INSTANCE.reversed())
.toList());
.collect(
Collectors.toMap(
Function.identity(),
x -> Boolean.TRUE,
(v1, v2) -> {
throw new IllegalStateException();
},
() -> new TreeMap<>(EventKeySortComparator.INSTANCE.reversed())))
.keySet())
.stream().toList();
}
@Override