如何在春季批处理中跳过ItemReader中的例外?
我正在使用春季批处理应用程序。我正在从桌子上读书并处理它。我的代码在下面看起来像
@Bean
public XPath.Step step1(JdbcPagingItemReader<Customer> reader, ItemProcessor processor, ItemWriter writer) {
return stepBuilderFactory.get("step1")
.<Customer, CustomerConverted>chunk(5)
.reader(reader)
.processor(processor)
.writer(writer)
.faultTolerant()
.skip(NullPointerException.class)
.skipLimit(3)
.listener(new SkipListener())
.build();
}
@Bean
public JdbcPagingItemReader<Customer> reader() throws Exception {
return new JdbcPagingItemReaderBuilder<Customer>()
.dataSource(dataSource)
.name("jdbcItemReader")
.queryProvider(queryProvider())
.rowMapper(CustomCustomerMapper) //CustomCustomerMapper is a bean injected
.pageSize(5)
.saveState(false)
.build();
}
CustomCustomerMapper,我正在模拟每块的1个NullPoInterException。有1个跳过侦听器调用,而不是3个,但工作状态已完成。
我的理解是,在读者中,如果每个块有1个例外,则应处理3个块,除了失败的记录和第4个块应按照上述配置失败。
但是我的应用程序并非如此。赞赏指导。
I am using spring batch application. I am reading from table and processing it. my code looks like below
@Bean
public XPath.Step step1(JdbcPagingItemReader<Customer> reader, ItemProcessor processor, ItemWriter writer) {
return stepBuilderFactory.get("step1")
.<Customer, CustomerConverted>chunk(5)
.reader(reader)
.processor(processor)
.writer(writer)
.faultTolerant()
.skip(NullPointerException.class)
.skipLimit(3)
.listener(new SkipListener())
.build();
}
@Bean
public JdbcPagingItemReader<Customer> reader() throws Exception {
return new JdbcPagingItemReaderBuilder<Customer>()
.dataSource(dataSource)
.name("jdbcItemReader")
.queryProvider(queryProvider())
.rowMapper(CustomCustomerMapper) //CustomCustomerMapper is a bean injected
.pageSize(5)
.saveState(false)
.build();
}
In CustomCustomerMapper, I am simulating 1 NullPointerException per chunk. There is 1 skip listener invocation instead of 3 but Job status is completed.
My understanding is if in reader there is 1 exception per chunk, 3 chunk should get processed except the failing record and 4th chunk should fail as per above config.
But my app is not behaving like that. Guidance is appreciated.
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论