[PAGOPA-2282] refactoring: Sequential stream

pagopa · Oct 28, 2024 · d452397 · d452397
1 parent 924ae47
commit d452397
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/it/gov/pagopa/fdr/service/psps/PspsService.java b/src/main/java/it/gov/pagopa/fdr/service/psps/PspsService.java
@@ -375,7 +375,8 @@ private void deleteAllInBatch(String fdr, List<FdrPaymentInsertEntity> paymentIn
             .mapToObj(i -> paymentInsertEntities.subList(i * batchSize, Math.min((i + 1) * batchSize, paymentInsertEntities.size())))
             .toList();
 
-    batches.parallelStream().forEach(batch -> {
+    // sequential stream
+    batches.forEach(batch -> {
       List<Long> indexes = paymentInsertEntities.stream().map(FdrPaymentInsertEntity::getIndex).toList();
       FdrPaymentInsertEntity.deleteByFdrAndIndexes(fdr, indexes);
     });