Hi,
I have several jobs which configured for external check-pointing
(enableExternalizedCheckpoints)
how can I correlate between checkpoint and jobs.
for example, if i want to write script which monitor if the job is up or
not and if the job is down it will resume the job from the externalized
checkpoint.
how could i know which checkpoint belong to the specific job?

can I configure each job to write the external check-pointing to a
different position?

my configuration is:
*state.backend*: rocksdb
*state.backend.fs.checkpointdir*: s3a://flink-bucket/backend/checkpoints
*state.checkpoints.dir*: s3a://flink-bucket/checkpoints

and in the code I set:
enableCheckpointing
enableExternalizedCheckpoints

Reply via email to