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 -> {