Re: how to match external checkpoints with jobs during recovery

2018-02-06 Thread Aljoscha Krettek
Hi, I'm afraid it's currently not possible to distinguish between externalised checkpoints when running multiple jobs on one JobManager because the externalised checkpoints of all jobs would be written to the same directory. In Flink 1.5 (which is not yet released, but the code for this is in m

how to match external checkpoints with jobs during recovery

2018-02-05 Thread xiatao123
The external checkpoints are in the format of checkpoint_metadata-0057 which I have no idea which job this checkpoint metadata belongs to if I have multiple jobs running at the same time. If a job failed unexpected, I need to know which checkpoints belongs to the failed job. Is there API o