Spring Batch任务未按预期终止却执行后续步骤问题排查

我接手了一个Spring Batch任务，遇到如下异常行为：VerifyPreditErrors步骤的configIBMTCompletionProcessor（ConfigIBMTCompletionProcessor.java）抛出异常，按步骤定义预期任务会终止——因为该异常应使ConfigIBMTCompletionWriter.java的afterStep()返回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定义 #

<bean id="compositeIBMTCompletionWriter" class="org.springframework.batch.item.support.CompositeItemWriter" scope="job">
    <property name="delegates">
        <list>
            <ref bean="configIBMTCompletionWriter" /> <!-- 无预编辑错误时更新表，否则发送邮件 -->
            <ref bean="flatFileItemWriterWrapper" /> <!-- 仅当发现预编辑错误时创建文件 -->
        </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.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) {}
}

相关日志输出

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

ConfigIBMTCompletionProcessor.java #

public class ConfigIBMTCompletionProcessor implements
    ItemProcessor<String, List<CustomParams>>, StepExecutionListener {
  // 从DB获取数据
  String status = service.fetchBatchWorkStatus();

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

  @Override
  public void beforeStep(StepExecution stepExecution) {
    // 一些预处理操作
  }

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

批处理任务步骤详情 #

问题 #

1. 为何任务会执行IBMTFileCopy步骤？明明ConfigIBMTCompletionWriter.java的afterStep()返回了ExitStatus.NOOP。
2. 为何VerifyPreditErrors步骤被标记为ABANDONED？

问题解答 #

问题1：为何执行了IBMTFileCopy步骤？ #

当configIBMTCompletionProcessor抛出异常时，Spring Batch会将步骤的默认退出状态设置为FAILED，此时步骤流转逻辑会优先匹配<batch:next on="FAILED" to="IBMTFileCopy"/>。

你的预期存在两个关键偏差：

• 处理器抛出异常后，chunk的writer不会被执行，configIBMTCompletionWriter作为CompositeItemWriter的委托之一，其write()方法未触发，导致类中status变量未正确赋值（日志显示status为null）。
• 即使afterStep()被调用并返回NOOP，但步骤因异常处于失败状态时，Spring Batch会使用步骤的异常退出状态而非监听器返回的状态进行流转判断——只有步骤正常完成时，监听器返回的ExitStatus才会覆盖默认值。

问题2：为何步骤被标记为ABANDONED？ #

ABANDONED状态通常出现在步骤执行过程中抛出未捕获异常，且Spring Batch无法正常完成步骤收尾工作时：

• 处理器抛出异常后，chunk事务会回滚，步骤执行状态先被标记为FAILED，若异常导致步骤上下文无法正常更新（比如事务回滚时出现隐性问题），或监听器逻辑干扰状态流转，就可能被标记为ABANDONED。
• 另外，configIBMTCompletionProcessor实现了StepExecutionListener但afterStep()返回null，这会导致Spring Batch无法正确处理步骤最终状态，进一步加剧状态异常。

内容的提问来源于stack exchange，提问作者waffledood