Spring Cloud Data Flow数据源错误时Spring Batch作业如何返回FAILED状态

解决方案 #

1. 拆分Spring Cloud Task监控数据源与业务数据源 #

这是最稳妥的方案，确保SCDF任务状态上报的链路不受业务数据源故障影响：

• 配置独立的数据源供Spring Cloud Task使用，该数据源配置需要确保正确性，用来存储任务执行日志、上报状态
• 业务作业使用的数据源单独配置，不与Task框架的数据源复用
  对应的配置示例：

# Spring Cloud Task 监控数据源（必选，配置正确保证状态上报链路正常）
spring:
  cloud:
    task:
      datasource:
        url: jdbc:mysql://xxx/scdf_task
        username: xxx
        password: xxx
        driver-class-name: com.mysql.cj.jdbc.Driver
  # 业务数据源（你的作业使用的数据源，允许配置错误）
  datasource:
    url: jdbc:mysql://xxx/biz_db
    username: xxx
    password: xxx
    driver-class-name: com.mysql.cj.jdbc.Driver
  jpa:
    hibernate:
      ddl-auto: none

同时要配置Task数据源的事务管理器不与业务事务管理器冲突，确保Task的状态上报逻辑不受业务数据源故障影响。

2. 懒加载业务相关Bean，将初始化异常移入作业执行逻辑 #

如果无法拆分数据源，可以将业务数据源、JPA实体管理器、业务作业相关Bean标记为懒加载，让它们的初始化时机从Spring上下文启动阶段推迟到作业执行阶段，这样异常就可以被你现有代码的try-catch块捕获：

// 业务数据源加懒加载
@Lazy
@Bean
@Primary
public DataSource bizDataSource(DataSourceProperties properties) {
    return properties.initializeDataSourceBuilder().build();
}

// JPA 实体管理器加懒加载
@Lazy
@Bean
public LocalContainerEntityManagerFactoryBean entityManagerFactory(DataSource bizDataSource) {
    LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
    em.setDataSource(bizDataSource);
    // 其余JPA配置省略
    return em;
}

调整后你的作业执行逻辑就可以捕获到数据源初始化失败的异常，此时你需要将异常抛出或者手动构造FAILED状态的JobExecution，不要直接吞掉异常只打印堆栈，否则SCDF无法识别到失败状态：

@Bean
public JobExecution run(JobLauncher jobLauncher) {
  JobExecution jobExecution = null;
  Job job;
  try {
    JobParameters jobParameters = new JobParametersBuilder().addLong("time", System.currentTimeMillis()).toJobParameters();
    job = BeanFactoryAnnotationUtils.qualifiedBeanOfType(ctx.getAutowireCapableBeanFactory(), Job.class, jobName);
    jobExecution = jobLauncher.run(job, jobParameters);
    log.info("Exit Status : " + jobExecution.getStatus());
  } catch (Exception e) {
    log.error("作业执行失败", e);
    // 方式1：直接抛出异常，Spring Cloud Task会自动上报FAILED状态
    throw new RuntimeException("作业执行失败", e);
    // 方式2：手动构造FAILED状态的JobExecution返回
    /*
    jobExecution = new JobExecution(1L);
    jobExecution.setStatus(BatchStatus.FAILED);
    jobExecution.setExitStatus(ExitStatus.FAILED.addExitDescription(e.getMessage()));
    return jobExecution;
    */
  }
  return jobExecution;
}

3. 确保Spring Cloud Task依赖与配置正确 #

要让SCDF正确识别任务状态，你需要在应用中引入spring-cloud-starter-task依赖，它会自动监听应用生命周期事件，包括上下文启动失败的事件，自动上报状态到SCDF：

<!-- Maven依赖示例 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-task</artifactId>
</dependency>

同时配置spring.cloud.task.enabled=true，确保Task功能正常启用。

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