Я унаследовал задание Spring Batch и пытаюсь понять следующее поведение.

Исключение было выброшено в configIBMTCompletionProcessor (ConfigIBMTCompletionProcessor.java) шага VerifyPreditErrors, и я ожидаю, что работа остановится в соответствии с определением шага.

Потому что выброшенное исключение ConfigIBMTCompletionProcessor.java должно привести к тому, что afterStep() в ConfigIBMTCompletionWriter.java вернется ExitStatus.NOOP. Таким образом, все пакетное задание должно завершиться.

Но этот шаг был отмечен как ABANDONED и мы перешли к следующему шагу IBMTFileCopy.

Определение шагов XML

        <batch:step id = "VerifyPreditErrors">
            <batch:tasklet>
                <batch:chunk reader = "iinnoOpReader" writer = "compositeIBMTCompletionWriter" processor = "configIBMTCompletionProcessor"
                    commit-interval = "1">
                </batch:chunk>
            </batch:tasklet>
            <batch:next on = "FAILED" to = "IBMTFileCopy"/>
            <batch:next on = "SUCCESS" to = "IBMTFetchDataCreateReport"/>
            <batch:end on = "NOOP"/>
            <batch:listeners>
                <batch:listener ref  = "configIBMTCompletionWriter"></batch:listener>
            </batch:listeners>
        </batch:step>

        <batch:step id = "IBMTFileCopy" >
            <batch:tasklet ref = "fileCopyTasklet">
            </batch:tasklet>
        </batch:step>   

Определение XML-компонентов

    <bean id = "compositeIBMTCompletionWriter" class = "org.springframework.batch.item.support.CompositeItemWriter" scope = "job">
        <property name = "delegates">
            <list>
                <ref bean = "configIBMTCompletionWriter" /> <!-- This will update the tables if no pre-edit errors, otherwise send an email -->
                <ref bean = "flatFileItemWriterWrapper" /> <!-- This will create a file only if pre-edit errors are found. -->
            </list>
        </property>
    </bean>

    <bean id = "configIBMTCompletionProcessor" class = "com.companyName.coreconfig.batch.processor.ConfigIBMTCompletionProcessor" />

    <bean id = "configIBMTCompletionWriter" class = "com.companyName.coreconfig.batch.writer.IBMTCompletionWriter" scope = "step">
        <property name = "fileName" value = "IBMT_ERR_RPT_#{jobParameters[dt]}.csv"/>
    </bean>

Определение Java

Компонент configIBMTCompletionWriter (ConfigIBMTCompletionWriter.java)

public class ConfigIBMTCompletionWriter implements ItemWriter<List<CustomParams>>,
    StepExecutionListener {

  @Override
  public void write(List<? extends List<CustomParams>> items) throws Exception {    
  ...
  }

  @Override
  public ExitStatus afterStep(StepExecution stepExecution) {
    logger.info("Setting the step status as: " + status);
    if (status.equals(Constants.SUCCESS)) {
      return new ExitStatus(Constants.SUCCESS);
    } else if (status.equals(Constants.FAILED)) {
      return new ExitStatus(Constants.FAILED);
    }
    return ExitStatus.NOOP;
  }

  @Override
  public void beforeStep(StepExecution stepExecution) {}
}

В журналах я вижу напечатанный журнал afterStep:

335601  main    INFO    com.companyName.coreconfig.batch.writer.ConfigIBMTCompletionWriter  ConfigIBMTCompletionWriter.java:169 Setting the step status as: null

Компонент configIBMTCompletionProcessor (ConfigIBMTCompletionProcessor.java)

public class ConfigIBMTCompletionProcessor implements
    ItemProcessor<String, List<CustomParams>>, StepExecutionListener {
  // fetch data from DB
  String status = service.fetchBatchWorkStatus();

  case (status) {
    ...
    case Constants.FAILED:
      throw Exception(...);
    ...
  }
}

  @Override
  public void beforeStep(StepExecution stepExecution) {
    // some pre-processing 
  }

  @Override
  public ExitStatus afterStep(StepExecution stepExecution) {
    // TODO Auto-generated method stub
    return null;
  }

Прилагается изображение с подробными сведениями об этапах пакетного задания:

Вопросы

1. Почему задание перешло к этапу IBMTFileCopy? Даже когда метод afterStep() в ConfigIBMTCompletionWriter.java вернулся ExitStatus.NOOP.

2. Почему шаг VerifyPreditErrors отмечен как ЗАБРОШЕННЫЙ?