I am looking to make the use of JobExecutionDecider in my Spring Batch App. I've taken reference: How to use decider in Spring batch?.
For the code I written I am getting below error. Note: Surely I don't want to override the beans in my code. Any suggestion why this error?
Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled.
2020-01-01 19:32:30.859 ERROR 13800 --- [ main] o.s.b.d.LoggingFailureAnalysisReporter :
***************************
APPLICATION FAILED TO START
***************************
Description:
The bean 'step1', defined in class path resource [com/example/config/JobConfig.class], could not be registered. A bean with that name has already been defined in class path resource [com/example/JobConfiguration.class] and overriding is disabled.
Action:
Consider renaming one of the beans or enabling overriding by setting spring.main.allow-bean-definition-overriding=true
JobConfig.java
@Slf4j
@Configuration
public class JobConfig {
@Autowired
private JobBuilderFactory jobBuilderFactory;
@Autowired
private StepBuilderFactory stepBuilderFactory;
@Bean
public Tasklet step1Tasklet() {
return new Step1Tasklet();
}
@Bean
public JobExecutionDecider decider() {
return new MyJobExecutionDecider();
}
@Bean
public Step step1() {
return stepBuilderFactory.get("step1")
.tasklet(step1Tasklet())
.build();
}
// Here I used inbuild Tasklet
@Bean
public Step step2() {
return stepBuilderFactory.get("step2")
.tasklet((contribution, chunkContext) -> {
log.debug("Step2Tasklet is executed...");
System.out.println("world");
return RepeatStatus.FINISHED;
})
.build();
}
@Bean
public Step step3() {
return stepBuilderFactory.get("step3")
.tasklet((contribution, chunkContext) -> {
log.debug("Step3Tasklet is executed...");
return RepeatStatus.FINISHED;
})
.build();
}
@Bean
public Job job() {
return jobBuilderFactory.get("myJob")
.start(step1())
.next(decider())
.on("YES").to(step2())
.from(decider()).on("NO").to(step3())
.end()
.build();
}
}
MyJobExecutionDecider.java
public class MyJobExecutionDecider implements JobExecutionDecider{
@Override
public FlowExecutionStatus decide(JobExecution jobExecution, StepExecution stepExecution) {
return new FlowExecutionStatus("YES");
}
}
Step1Tasklet.java
@Slf4j
public class Step1Tasklet implements Tasklet{
@Override
public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
log.debug("Step1Tasklet is executed...");
chunkContext.getStepContext().getStepExecution().setExitStatus(new ExitStatus("YES")); // or NO
return RepeatStatus.FINISHED;
}
}
SpringBatchDeciderApplication.java
@SpringBootApplication
@EnableBatchProcessing
public class SpringBatchDeciderApplication {
public static void main(String[] args) {
SpringApplication.run(SpringBatchDeciderApplication.class, args);
}
}
I have tried with your example. Basically I copied your code and ran (except I remove a line in Tasklet). It is working fine. I have pushed the code at github at https://github.com/bigzidane/spring-batch-validate-reader
Please pull and try by yourself. Put comments in case you are having the same issue.
If decider is Yes, it was executing Step1 and Step2
If decider is No, it was executing Step1 and Step3