Re: Flink Version 1.11 job savepoint failures

2021-05-03 Thread Rainie Li
It helps. Thanks Matthias. Best regards Rainie On Mon, May 3, 2021 at 4:25 AM Matthias Pohl wrote: > Hi Rainie, > the savepoint creation failed due to some tasks already being finished. It > looks like you ran into an issue that was (partially as FLINK-21066 [1] is > only a subtask of a bigger

Re: Flink Version 1.11 job savepoint failures

2021-05-03 Thread Matthias Pohl
Hi Rainie, the savepoint creation failed due to some tasks already being finished. It looks like you ran into an issue that was (partially as FLINK-21066 [1] is only a subtask of a bigger issue?) addressed in Flink 1.13 (see FLINK-21066). I'm pulling Yun Gao into this thread. Let's see whether Yun

Flink Version 1.11 job savepoint failures

2021-05-03 Thread Rainie Li
Hi Flink Community, Our flink jobs are in version 1.11 and we use this to trigger savepoint. $ bin/flink savepoint :jobId [:targetDirectory] We can get trigger Id with savepoint path successfully. But we saw these errors by querying savepoint endpoint: