Spring Batch条件流配置异常求助：按文件类型分支执行失败

从你的配置来看，导致流程执行失败的核心问题有两个，我来逐一拆解并给出修复方案：

1. Tasklet未正确设置Step的ExitStatus #

Spring Batch的作业流分支是基于Step的ExitStatus来判断的，但你当前仅将文件类型存入执行上下文，并未将其设置为Step的退出状态。这会导致retrieveFileStep执行完成后，默认ExitStatus为COMPLETED，作业流找不到匹配YEARLY或QUARTERLY的分支，最终触发流程失败。

你需要修改FileRetrievingTasklet的execute方法，将文件类型设置为Step的ExitStatus：

@Override
public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
    // 拉取远程文件的业务逻辑
    String fileType = this.getRemoteFileType(); // 替换为你获取文件类型的实际代码
    // 将文件类型存入执行上下文（供后续步骤使用）
    chunkContext.getStepContext().getJobExecutionContext().put("fileType", fileType);
    // 关键操作：设置Step的ExitStatus为文件类型
    contribution.setExitStatus(new ExitStatus(fileType));
    return RepeatStatus.FINISHED;
}

2. 作业流配置存在重复创建Step的问题 #

你当前的代码中，每次调用retrieveFileStep(stepBuilderFactory)都会生成一个全新的Step实例。这意味着from(retrieveFileStep(...))指向的不是最初启动的拉取文件Step，而是一个新实例，会导致重复执行拉取操作（可能因文件已被拉取、资源不存在等原因失败）。

正确的做法是先实例化retrieveFileStep并复用，同时完善分支逻辑，添加默认分支处理未知文件类型：

@Bean 
public Job fundsDistributionJob() { 
    // 先实例化拉取文件的Step，避免重复创建
    Step retrieveFileStep = retrieveFileStep(stepBuilderFactory);
    
    return jobBuilderFactory 
        .get("fundsDistributionJob") 
        .start(retrieveFileStep)
        // ExitStatus为YEARLY时，跳转到yearEndStep
        .on("YEARLY").to(yearEndStep())
        // 回到retrieveFileStep的分支，匹配QUARTERLY时跳转到quarterlyStep
        .from(retrieveFileStep)
        .on("QUARTERLY").to(quarterlyStep())
        // 处理所有未匹配的ExitStatus，直接结束流程
        .from(retrieveFileStep)
        .on("*").end()
        // 结束分支配置
        .end() 
        .listener(new FileWorkerJobExecutionListener()) 
        .build(); 
}

同时确保retrieveFileStep是正确的Tasklet Step配置：

@Bean
public Step retrieveFileStep(StepBuilderFactory stepBuilderFactory) {
    return stepBuilderFactory.get("retrieveFileStep")
            .tasklet(fileRetrievingTasklet()) // 注入你的FileRetrievingTasklet实例
            .build();
}

额外检查点 #

如果修复后仍然失败，建议排查：

• FileRetrievingTasklet的拉取逻辑是否存在未捕获的异常（比如网络问题、文件不存在），未处理的异常会直接导致Step状态为FAILED。
• 确认yearEndStep()和quarterlyStep()的配置本身无问题（比如Reader/Processor/Writer的依赖是否正确注入）。

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