How can I get last successful checkpoint id in sink?

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

How can I get last successful checkpoint id in sink?

yunfan123
It seems flink not support this?
Reply | Threaded
Open this post in threaded view
|

Re: How can I get last successful checkpoint id in sink?

Tzu-Li (Gordon) Tai
Hi!

The last completed checkpoint ID should be obtainable using the monitoring REST API [1], under the url “/jobs/{jobID}/checkpoints/“.

It is also visible in the JobManager Web UI under the “checkpoints” tab of each job. The web UI fetches its information using the monitoring REST API, so anything available there should also be retrievable via the REST API.

Cheers,
Gordon

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.3/monitoring/rest_api.html


On 18 June 2017 at 2:24:31 PM, yunfan123 ([hidden email]) wrote:

It seems flink not support this?



--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/How-can-I-get-last-successful-checkpoint-id-in-sink-tp13815.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.