CODEWITHSUNDEEP
jsr352java-batch
Fazil Hussain
Fazil Hussain

Reputation: 425

JSR 352. Restarting partitions : How to checkpoint the commits?

I have a partitioned job that reads from and writes to a DB. I have a chunking size of 100. If a partition fails and i want the restart to happen from the last commit, do i have to explicitly specify the checkpoint? (in Serializable checkpointInfo()?)

If so how/where?

Upvotes: 1

Views: 573

Answers (1)

Scott Kurz
Scott Kurz

Reputation: 5320

Answer

You need to implement the pair of methods: checkpointInfo() and open() for your ItemReader (and you can for your ItemWriter as well).

Example

You can see an example in this answer.

More info

Note that for a partitioned step, each partition has its own checkpoint. In this way the programming model is very similar from the reader/processor/writer perspective across partitioned and non-partitioned steps, and so they can be written independently of whether or not they are running in a partition (for the most part).

Upvotes: 2

Related Questions