Spring Cloud Data Flow组合任务CommandLineRunner执行前异常处理咨询

Spring Cloud Task的执行状态需要写入SCDF提供的Task/Batch数据源，出现UNKNOWN状态的本质是：业务数据源初始化失败发生在Spring Cloud Task核心组件初始化完成之前，任务进程还没来得及将执行结果上报到SCDF的元数据库就已经退出，因此SCDF只能识别到Pod异常，但无法关联到具体的Task执行记录，最终标记为UNKNOWN。

1. 调整Bean初始化顺序，优先初始化Task核心组件 #

强制让Spring Cloud Task的状态管理相关Bean在业务数据源之前完成初始化，保证出现异常时已经具备上报状态的能力：

• 给自定义的业务数据源Bean添加@DependsOn注解，指定依赖Task核心组件：

@Bean
@DependsOn({"taskExecutionDao", "taskExplorer"})
public DataSource businessDataSource() {
    // 业务数据源初始化逻辑
}

• 确认CustomTaskConfigurer注入的batchDataSource确实是SCDF提供的Task元数据库数据源，不要误注入业务数据源，否则状态上报本身就会失效。

2. 添加上下文初始化失败监听器，手动上报失败状态 #

实现Spring的ApplicationListener<ApplicationContextFailedEvent>，在上下文刷新失败时主动更新Task执行状态：

@Component
@ConditionalOnBean(TaskExecutionDao.class)
public class ContextFailedListener implements ApplicationListener<ApplicationContextFailedEvent> {

    @Autowired
    private TaskExecutionDao taskExecutionDao;

    @Value("${spring.cloud.task.executionid:}")
    private Long taskExecutionId;

    @Override
    public void onApplicationEvent(ApplicationContextFailedEvent event) {
        if (taskExecutionId == null) {
            return;
        }
        TaskExecution execution = taskExecutionDao.getTaskExecution(taskExecutionId);
        if (execution == null || execution.getEndTime() != null) {
            return;
        }
        // 更新状态为失败
        execution.setEndTime(new Date());
        execution.setExitCode(ExitCode.FAILED.getExitCode());
        execution.setExitMessage("上下文初始化失败: " + event.getException().getMessage());
        execution.setStatus(TaskStatus.FAILED);
        taskExecutionDao.update(execution);
    }
}

3. 调整Composed Task DSL匹配执行逻辑 #

当前使用的JobA && JobB规则是仅当JobA执行成功时才触发JobB，如果需求是无论JobA成功失败都要执行JobB，将DSL修改为：

JobA ; JobB

如果需求是仅当JobA失败时才触发JobB，修改为：

JobA || JobB

注意：以上规则生效的前提是JobA能正确上报FAILED状态而非UNKNOWN，否则Composed Task执行引擎无法识别任务已结束，会一直等待或跳过后续步骤。

4. 补充配置项 #

在Task的应用配置中添加以下配置，增强异常场景下的状态上报能力：

spring:
  cloud:
    task:
      fail-on-task-execution-failure: true
      close-context-enabled: true

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