diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/step/builder/SimpleStepBuilder.java b/spring-batch-core/src/main/java/org/springframework/batch/core/step/builder/SimpleStepBuilder.java index 79cea8e86..40aa86f21 100644 --- a/spring-batch-core/src/main/java/org/springframework/batch/core/step/builder/SimpleStepBuilder.java +++ b/spring-batch-core/src/main/java/org/springframework/batch/core/step/builder/SimpleStepBuilder.java @@ -64,6 +64,7 @@ import org.springframework.util.Assert; * * @author Dave Syer * @author Mahmoud Ben Hassine + * @author Parikshit Dutta * * @since 2.2 */ @@ -111,6 +112,7 @@ public class SimpleStepBuilder extends AbstractTaskletStepBuilder reader = new ListItemReader<>(items); ListItemWriter itemWriter = new ListItemWriter<>(); - @SuppressWarnings("unchecked") + SimpleStepBuilder builder = new StepBuilder("step") - .repository(jobRepository) - .transactionManager(transactionManager) - .chunk(3) - .reader(reader) - .processor((Function) s -> s.toString()) - .writer(itemWriter) - .listener(new AnnotationBasedStepExecutionListener()); + .repository(jobRepository) + .transactionManager(transactionManager) + .chunk(3) + .reader(reader) + .processor((Function) s -> s.toString()) + .writer(itemWriter) + .listener(new AnnotationBasedStepExecutionListener()); + + if (faultTolerantStep) { + builder = builder.faultTolerant(); + } builder.build().execute(execution); assertEquals(BatchStatus.COMPLETED, execution.getStatus());