Spring Batch/Data JPA应用在K8s环境下数据未持久化问题排查

本地环境运行完全正常的批处理应用，部署到K8s集群Pod后出现异常：自定义ItemWriter中前两个针对MySecondRepo的数据库操作正常生效，但最后一个myfirstRepo.saveAll操作无法将数据持久化到数据库，无任何报错，作业执行标记为成功但目标数据未更新。

一、核心配置说明 #

内存模式Job Repository配置 #

通过重写setDataSource禁用默认数据源，使用基于内存的Job Repository，搭配ResourcelessTransactionManager：

@Configuration
@EnableBatchProcessing
public class BatchConfigurer extends DefaultBatchConfigurer {

    @Override
    public void setDataSource(DataSource dataSource){
        // 空实现，启用内存Job Repository
    }
}

已在配置文件中设置spring.main.allow-bean-definition-overriding=true，确认自定义事务管理器绑定正确。

自定义ItemWriter实现 #

public class MyWriter implements ItemWriter<MyDTO> {

    @Autowired
    private MyFirstRepo myfirstRepo; // 对应第一个数据源的仓库

    @Autowired
    private MySecondRepo mySecondRepo; // 对应第二个数据源的仓库
    
    @Override
    public void write(List<? extends MyDTO> myDtoList) throws Exception {
        // 业务逻辑：正常生效
        mySecondRepo.delete(deletableEntity);

        // 业务逻辑：正常生效
        mySecondRepo.saveAll(updatableEntities);

        // 业务逻辑：K8s中无持久化效果
        myfirstRepo.saveAll(updatableEntities);
    }
}

链式事务管理器与Step配置 #

整合两个JpaTransactionManager的链式事务管理器

@Configuration
public class TransactionManagerConfig {

    @Primary
    @Bean(name = "chainedTransactionManager")
    public ChainedTransactionManager transactionManager(
            @Qualifier("firstTransactionManager") PlatformTransactionManager firstTransactionManager,
            @Qualifier("secondTransactionManager")PlatformTransactionManager secondTransactionManager) {
        return new ChainedTransactionManager(firstTransactionManager, secondTransactionManager);
    }
}

Step绑定事务管理器

@Bean
public Step myStep(@Qualifier("chainedTransactionManager") ChainedTransactionManager chainedTransactionManager) {
    return getCommonStepBuilder("myStep")
            .transactionManager(chainedTransactionManager)
            .<MyDTO, MyDTO>chunk(200)
            .reader(myPaginingReader())
            .writer(myWriter())
            .taskExecutor(myTaskExecutor())
            .throttleLimit(15)
            .build();
}

临时解决方法 #

将myfirstRepo.saveAll操作拆分为独立的Jdbc批处理ItemWriter，与原MyWriter组合为CompositeItemWriter后，数据持久化恢复正常。

疑问点 #

1. JdbcPagingItemReader获取的实体是否处于非托管状态？MySecondRepo操作的实体是Writer内通过Hibernate查询所得，而myfirstRepo操作的实体直接来自Reader。
2. 为何相同代码在本地环境完全正常，仅在K8s集群中出现异常？

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