Spring Batch中Chunk Size与DEFAULT_PARTITION_SIZE的区别及疑问

核心概念区别 #

• Chunk Size：Spring Batch内置的核心配置，用于定义单次事务边界内处理的记录数。你理解的逻辑是对的：框架会按配置的数值（比如你设置的25）读取对应数量的记录，完成处理后一次性写入，随后提交事务。这个参数通常通过Step配置中的chunk(25)方式指定，是控制批处理事务粒度的标准方式。
• DEFAULT_PARTITION_SIZE：Spring Batch本身没有这个内置参数，这是你通过jobExecution.getExecutionContext().put()手动存入作业执行上下文的自定义参数。框架不会自动用它来控制Chunk的处理逻辑，它的作用完全由你项目中的自定义代码决定。

实际写入300条的原因 #

你预期每次写入25条但实际是300条，问题出在你的项目代码中，有逻辑误将这个自定义的DEFAULT_PARTITION_SIZE值当成了Chunk Size来使用，覆盖了你原本设置的25：

1. 检查ItemWriter实现：如果你的Writer没有遵循Chunk Size的约定，而是主动读取了执行上下文中的DEFAULT_PARTITION_SIZE作为批量写入的数量，就会导致每次写300条。
2. 排查自定义批处理逻辑：比如是否存在拦截器、动态Step配置逻辑，将DEFAULT_PARTITION_SIZE的值替换了原本的Chunk Size配置。
3. 确认Step配置有效性：检查你的Step是否确实通过chunk(25)设置了Chunk Size，没有被其他代码动态修改。

排查建议 #

• 全局搜索项目中DEFAULT_PARTITION_SIZE的读取位置，重点关注ItemWriter、Step配置、批处理拦截器相关代码。
• 查看作业执行日志，查找关于Chunk处理的日志输出，确认实际生效的Chunk Size数值，定位修改逻辑的来源。

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