diff --git a/src/main/java/org/gcube/accounting/aggregator/persist/DeleteDocument.java b/src/main/java/org/gcube/accounting/aggregator/persist/DeleteDocument.java index d5f4807..02e727d 100644 --- a/src/main/java/org/gcube/accounting/aggregator/persist/DeleteDocument.java +++ b/src/main/java/org/gcube/accounting/aggregator/persist/DeleteDocument.java @@ -29,7 +29,6 @@ public class DeleteDocument extends DocumentElaboration { JsonNode jsonNode = DSMapper.asJsonNode(line); if(aggregatorPersistenceSrc.isBulkDeleteAllowed()) { arrayNode.add(jsonNode); - aggregatorPersistenceSrc.deleteRecord(jsonNode); if(arrayNode.size()>=effectiveMaxRowPerStep) { aggregatorPersistenceSrc.deleteRecords(arrayNode); arrayNode = DSMapper.getObjectMapper().createArrayNode();