diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/step/tasklet/TaskletStep.java b/spring-batch-core/src/main/java/org/springframework/batch/core/step/tasklet/TaskletStep.java index 1fa0522e8..4422b8b85 100644 --- a/spring-batch-core/src/main/java/org/springframework/batch/core/step/tasklet/TaskletStep.java +++ b/spring-batch-core/src/main/java/org/springframework/batch/core/step/tasklet/TaskletStep.java @@ -279,8 +279,6 @@ public class TaskletStep extends AbstractStep { } } - chunkListener.afterChunk(); - } finally { @@ -390,6 +388,8 @@ public class TaskletStep extends AbstractStep { } } + chunkListener.afterChunk(); + // Check for interruption after transaction as well, so that // the interrupted exception is correctly propagated up to // caller