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

DBZ-7047 Don't use parallel streaming

Browse Source 
Using parallel streams, this causes a severe loss of performance.
This commit is contained in:
Chris Cranford 2023-10-17 08:08:50 -04:00 committed by Chris Cranford
parent a3affaf6a8
commit 642b720982
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/infinispan/AbstractInfinispanLogMinerEventProcessor.java
View File

@ -285,7 +285,7 @@ protected int getTransactionEventCount(InfinispanTransaction transaction) {
// todo: implement indexed keys when ISPN supports them
return (int) getEventCache()
.keySet()
.parallelStream()
.stream()
.filter(k -> k.startsWith(transaction.getTransactionId() + "-"))
.count();
}