Re: In consistent Check point API response

2020-05-27 Thread Vijay Bhaskar
er/docs/monitoring/checkpoint_monitoring.zh.md >> >> Best >> Yun Tang >> -- >> *From:* Vijay Bhaskar >> *Sent:* Tuesday, May 26, 2020 15:18 >> *To:* Yun Tang >> *Cc:* user >> *Subject:* Re: In consistent Check po

Re: In consistent Check point API response

2020-05-27 Thread Vijay Bhaskar
/blob/master/docs/monitoring/checkpoint_monitoring.zh.md > > Best > Yun Tang > -- > *From:* Vijay Bhaskar > *Sent:* Tuesday, May 26, 2020 15:18 > *To:* Yun Tang > *Cc:* user > *Subject:* Re: In consistent Check point API response > > Thank

Re: In consistent Check point API response

2020-05-26 Thread Yun Tang
flink/blob/master/docs/monitoring/checkpoint_monitoring.zh.md Best Yun Tang From: Vijay Bhaskar Sent: Tuesday, May 26, 2020 15:18 To: Yun Tang Cc: user Subject: Re: In consistent Check point API response Thanks Yun. How can i contribute better documentation of t

Re: In consistent Check point API response

2020-05-26 Thread Vijay Bhaskar
mplementation of Flink, it will create the checkpoint statics > without restored checkpoint and assign it once the latest > savepoint/checkpoint is restored. [1] > > [1] > https://github.com/apache/flink/blob/50253c6b89e3c92cac23edda6556770a63643c90/flink-runtime/src/main/java/org/apache

Re: In consistent Check point API response

2020-05-26 Thread Yun Tang
__ From: Vijay Bhaskar Sent: Tuesday, May 26, 2020 12:19 To: Yun Tang Cc: user Subject: Re: In consistent Check point API response Hi Yun Understood the issue now: "restored" always shows only the check point that is used for restoring previous state In all the

Re: In consistent Check point API response

2020-05-25 Thread Vijay Bhaskar
b.com/apache/flink/blob/8f992e8e868b846cf7fe8de23923358fc6b50721/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java#L1250 > > Best > Yun Tang > ------ > *From:* Vijay Bhaskar > *Sent:* Monday, May 25, 2020 17:01 > *To:

Re: In consistent Check point API response

2020-05-25 Thread Yun Tang
:01 To: Yun Tang Cc: user Subject: Re: In consistent Check point API response Thanks Yun. Here is the problem i am facing: I am using jobs/:jobID/checkpoints API to recover the failed job. We have the remote manager which monitors the jobs. We are using "restored" field of the API re

Re: In consistent Check point API response

2020-05-25 Thread Vijay Bhaskar
t; savepoint/checkpoint is restored. [1] > > [1] > https://github.com/apache/flink/blob/50253c6b89e3c92cac23edda6556770a63643c90/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java#L1285 > > Best > Yun Tang > > --

Re: In consistent Check point API response

2020-05-25 Thread Yun Tang
ckpointCoordinator.java#L1285 Best Yun Tang From: Vijay Bhaskar Sent: Monday, May 25, 2020 14:20 To: user Subject: In consistent Check point API response Hi I am using flink retained check points and along with jobs/:jobid/checkpoints API for retrieving t

In consistent Check point API response

2020-05-24 Thread Vijay Bhaskar
Hi I am using flink retained check points and along with jobs/:jobid/checkpoints API for retrieving the latest retained check point Following the response of Flink Checkpoints API: I have my jobs restart attempts are 5 check point API response in "latest" key, check point file name of both "rest