如何在春季批处理中跳过ItemReader中的例外?

发布于 2025-01-23 13:32:36 字数 1120 浏览 2 评论 0原文

我正在使用春季批处理应用程序。我正在从桌子上读书并处理它。我的代码在下面看起来像

@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 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文