childJob 두번 실행

위 소스를 그대로 실행해 보니 childJob  이 두번 실행되는 현상은 발생하지 않고 있습니다.

1 : parentJob  실행

2 : jobStep 실행

3 : childJob 실행,  JobParameters 에 {name:user1} 저장

4 : step1 실행

5 : step1 의 tasklet 실행

6 : step1 실행 완료

7 : childJob 실행완료

8 : jobStep 실행완료

9 : step2 실행

10 : step2 실행완료

11 : parentJob 실행완료

순으로 실행이 정상적으로 이루어지고 있습니다.

이미지는 다른이름으로 저장한다음 보시거나 브라우저를 확대해서 보시면 됩니다.

다시 한번 확인해 보시기 바랍니다.

죄송하지만 전체 소스 공유 부탁드립니다

제가 실행하는 환경이나 소스가 동일한지 확인이 필요할 것 같습니다

안녕하세요. 저도 윗 분과 동일하게 childJob이 두 번 실행되는 현상이 있습니다. 코드는 정수원님의 깃헙에 있는 코드와 동일하게 실행하였고,  args = --job.name=parentJob date=20220309 로 하였습니다.

디버그로 확인해보니, jobStep으로 childJob이 실행되고, 맨 마지막에 childJob 별도의 Job으로 실행되었습니다.

1 : parentJob  실행

2 : jobStep 실행

3 : childJob 실행,  JobParameters 에 {name:user1} 저장

4 : step1 실행

5 : step1 의 tasklet 실행

6 : step1 실행 완료

7 : childJob 실행완료

8 : jobStep 실행완료

9 : step2 실행

10 : step2 실행완료

11 : parentJob 실행완료

12 : childJob 실행 

13 : step1 실행

14 : childJob 종료

답변이 늦어서 죄송합니다.

밑에 소스공유하겠습니다.

import lombok.RequiredArgsConstructor;
import org.springframework.batch.core.*;
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.batch.core.scope.context.ChunkContext;
import org.springframework.batch.core.step.job.DefaultJobParametersExtractor;
import org.springframework.batch.core.step.job.JobParametersExtractor;
import org.springframework.batch.core.step.tasklet.Tasklet;
import org.springframework.batch.repeat.RepeatStatus;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
@RequiredArgsConstructor
public class JobStepConfiguration {

    private final JobBuilderFactory jobBuilderFactory;
    private final StepBuilderFactory stepBuilderFactory;

    @Bean
    public Job parentJob(){
        return jobBuilderFactory.get("parentJob")
                .start(jobStep(null))
                .next(step2())
                .build();
    }

    @Bean
    public Step jobStep(JobLauncher jobLauncher) {
        return stepBuilderFactory.get("jobStep")
                .job(childJob())
                .launcher(jobLauncher)
                .parametersExtractor(jobParametersExtractor())
                .listener(new StepExecutionListener() {
                    @Override
                    public void beforeStep(StepExecution stepExecution) {
                        stepExecution.getExecutionContext().putString("name","user1");
                    }

                    @Override
                    public ExitStatus afterStep(StepExecution stepExecution) {
                        return null;
                    }
                })
                .build();
    }


    private JobParametersExtractor jobParametersExtractor() {
        DefaultJobParametersExtractor extractor = new DefaultJobParametersExtractor();
        extractor.setKeys(new String[]{"name"});
        return extractor;
    }

    @Bean
    public Job childJob() {
        return jobBuilderFactory.get("childJob")
                .start(step1())
                .build();
    }

    @Bean
    public Step step1() {
        return stepBuilderFactory.get("step1")
                .tasklet(new Tasklet() {
                    @Override
                    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
                        System.out.println("step1 was executed");
//                        throw new RuntimeException("childJob was failed");
                        return RepeatStatus.FINISHED;
                    }
                })
                .build();
    }

    @Bean
    public Step step2() {
        return stepBuilderFactory.get("step2")
                .tasklet(new Tasklet() {
                    @Override
                    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {

                        return RepeatStatus.FINISHED;
                    }
                })
                .build();
    }

}

강의와 동일한 소스에서 실행하는건가요?

아니면 소스 공유 가능할까요?