From abf29b71bac0ea9a6447fe762ba39d1de008ce9a Mon Sep 17 00:00:00 2001 From: Kilian Schuettler Date: Wed, 6 Nov 2024 15:49:49 +0100 Subject: [PATCH] RED-10418: improve unprocessed merge performance --- .../management/v1/processor/service/EntityLogMergeService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/EntityLogMergeService.java b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/EntityLogMergeService.java index 99d60512c..0717fb7e1 100644 --- a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/EntityLogMergeService.java +++ b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/EntityLogMergeService.java @@ -125,7 +125,7 @@ public class EntityLogMergeService { Map trackLocalChangesBasedOnDictEntriesMap, int analysisNumber) { - var dictEntryIdsToUpdate = trackLocalChangesBasedOnDictEntriesMap.values(); + Set dictEntryIdsToUpdate = new HashSet<>(trackLocalChangesBasedOnDictEntriesMap.values()); entityLogEntries.stream() .filter(entityLogEntry -> dictEntryIdsToUpdate.contains(entityLogEntry.getId())) .forEach(entityLogEntry -> {