From f2a12eca46094200e52724744353efdebcfb1488 Mon Sep 17 00:00:00 2001 From: dsyer Date: Wed, 23 Jul 2008 08:43:26 +0000 Subject: [PATCH] More careful accounting in AbstractTransactionalResourceItemWriter --- .../item/database/AbstractTransactionalResourceItemWriter.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/AbstractTransactionalResourceItemWriter.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/AbstractTransactionalResourceItemWriter.java index 72c91c111..e6dbc7570 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/AbstractTransactionalResourceItemWriter.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/AbstractTransactionalResourceItemWriter.java @@ -124,6 +124,9 @@ public abstract class AbstractTransactionalResourceItemWriter implements Item // failed item (from a failed chunk but we don't know which one was // the problem). RepeatSynchronizationManager.setCompleteOnly(); + // Remove the failed item from the cache, otherwise it could grow + // unnecessarily large. + failed.remove(output); // Flush now, so that if there is a failure this record can be // skipped. flush();