spring batch JdbcPagingItemReader作业重新启动并只选择尚未选择的记录

Question

null

@Bean
public JdbcPagingItemReader<NotificationRequest> notificationRequestJdbcPagingItemReader() {
    JdbcPagingItemReader<NotificationRequest> reader = new JdbcPagingItemReader<>();

    reader.setDataSource(this.dataSource);
    reader.setFetchSize(1000);
    reader.setRowMapper(new SmsSQLRowMapper());

    PostgresPagingQueryProvider queryProvider = new PostgresPagingQueryProvider();
    queryProvider.setSelectClause("subscriber_fk, event_time, record_flag, batch_date, message_type, cents_loanable, request_id, reason_code");
    queryProvider.setFromClause("from tbl_sms_tracker_new");

    Map<String, Order> sortKeys = new HashMap<>(1);

    sortKeys.put("request_id", Order.ASCENDING);

    queryProvider.setSortKeys(sortKeys);

    reader.setQueryProvider(queryProvider);

    return reader;
}

@Bean
public ItemWriter<NotificationRequest> notificationRequestAmqpItemWriter() {
    AmqpTemplate aTemplate = (AmqpTemplate) applicationContext.getBean("amqpTemplate");

    AmqpItemWriter<NotificationRequest> itemWriter = new AmqpItemWriter<>(aTemplate);

    return itemWriter;
}


@Bean
public Step step1() {
    return stepBuilderFactory.get("notificationStep1")
            .<NotificationRequest, NotificationRequest>chunk(1000)
            .reader(notificationRequestJdbcPagingItemReader())
            .writer(notificationRequestAmqpItemWriter())
            .faultTolerant()
            .build();
}


@Bean
public Job job() {
    return jobBuilderFactory.get("notificationJob")
            .start(step1())
            .build();
}

Answer 1

预期行为：

1. 成功重新启动作业

如果突然停止作业(kill-9)，那么JobRepository无法知道作业的当前状态，因为之前没有人告诉它。您的作业可能仍然处于started状态，而它不是（它已被杀死）。这就是为什么当试图重新启动一个被杀死的作业时会出现异常。您必须手动告诉作业存储库，您知道执行失败或应该被视为中止。有关这方面的更多详细信息：https://docs.spring.io/spring-batch/4.0.x/reference/html/job.html#aborting-a-job