Spring Batch Flowの実行で無限ループになってしまう

Question

前提・実現したいこと

Spring Batchを作成しています。
実行時に分岐する為、処理をまとめたいと思いますが、FlowBuilderで作成したFlowをJobへ渡すと
最初の処理が終わらなくなってしまいます。

最終的にやりたいことは
Step1がOKだったら、Step2・Step3・Step4の順で実行
Step1がNGだったら、Step3・Step4を実行
のようにしたく、Step3とStep4をまとめたいため、Flowを使用しようとしております。
※下記ソースコードではまだ分岐まで行っておらず、Flowで処理をまとめるところでつまずいております。

発生している問題・エラーメッセージ

下記ソースにて無限ループになってしまいます。

該当のソースコード

  @Bean
  public Job job(@Qualifier("flow1") final Flow flow1
  )
      throws Exception {

    return jobBuilderFactory.get(_JOB_NAME)
        .incrementer(new RunIdIncrementer())
        .start(flow1)
        .end()
        .build();
  }
  
  @Bean
  public Flow flow1(
      @Qualifier("step1") final Step step1,
      @Qualifier("step2") final Step step2) throws Throwable {
    return new FlowBuilder<SimpleFlow>("retryModeFlow")
        .start(step1)
        .next(step2)
        .build();
  }

  
  @Bean
  public Step step1() throws Throwable {
    return stepBuilderFactory
        .get(_JOB_STEP_NAME)
        .tasklet(new Tasklet() {
          @Override public RepeatStatus execute(StepContribution contribution,
              ChunkContext chunkContext) throws Exception {
            System.out.println("step1");
            return RepeatStatus.FINISHED;
          }
        })
        .build();
  }
  
  @Bean
  public Step step2() throws Throwable {
    return stepBuilderFactory
        .get(_JOB_STEP_NAME)
        .tasklet(new Tasklet() {
          @Override public RepeatStatus execute(StepContribution contribution,
              ChunkContext chunkContext) throws Exception {
            System.out.println("step2");
            return RepeatStatus.FINISHED;
          }
        })
        .build();
  }

上記を実行したところ、結果が

step1
step1
step1
step1
step1
...

となってしまいます。

試したこと

Flowを使用せずJobBuilterに直接Stepを渡した場合だと、正常に終了いたします。

  @Bean
  public Job job(@Qualifier("flow1") final Flow flow1
  )
      throws Exception {

    return jobBuilderFactory.get(_JOB_NAME)
        .incrementer(new RunIdIncrementer())
        .start(step1)
        .next(step2)
        .build();
  }
  
  
  @Bean
  public Step step1() throws Throwable {
    return stepBuilderFactory
        .get(_JOB_STEP_NAME)
        .tasklet(new Tasklet() {
          @Override public RepeatStatus execute(StepContribution contribution,
              ChunkContext chunkContext) throws Exception {
            System.out.println("step1");
            return RepeatStatus.FINISHED;
          }
        })
        .build();
  }
  
  @Bean
  public Step step2() throws Throwable {
    return stepBuilderFactory
        .get(_JOB_STEP_NAME)
        .tasklet(new Tasklet() {
          @Override public RepeatStatus execute(StepContribution contribution,
              ChunkContext chunkContext) throws Exception {
            System.out.println("step2");
            return RepeatStatus.FINISHED;
          }
        })
        .build();
  }

step1
step2

補足情報（FW/ツールのバージョンなど）

こちらを参考に作成しております。
https://spring.pleiades.io/spring-batch/docs/current/reference/html/step.html#external-flows

Versions
spring-boot-starter-parent : 2.0.1.RELEASE

お詳しい方、ご教授の程よろしくお願いいたします。

Answer 1

初歩的なミスでした。。
step1, step2のget(/* step名 */)のところで、同じ変数を渡してしまっており
同じ名前になってしまっていたことが原因でした。

以下修正点のみ抜粋。

  @Bean
  public Step step1() throws Throwable {
    return stepBuilderFactory
        .get("step1") // ここを修正
        .tasklet(new Tasklet() {
          @Override public RepeatStatus execute(StepContribution contribution,
              ChunkContext chunkContext) throws Exception {
            System.out.println("step1");
            return RepeatStatus.FINISHED;
          }
        })
        .build();
  }

  @Bean
  public Step step2() throws Throwable {
    return stepBuilderFactory
        .get("step2") // ここを修正
        .tasklet(new Tasklet() {
          @Override public RepeatStatus execute(StepContribution contribution,
              ChunkContext chunkContext) throws Exception {
            System.out.println("step2");
            return RepeatStatus.FINISHED;
          }
        })
        .build();
  }

上記の修正をすることで解決いたしました。
ご覧になってくださった方、ありがとうございました。