Hi min, If it is only for monitoring purposes, you can just use checkpoint REST API[1] to do this work.
[1]: https://ci.apache.org/projects/flink/flink-docs-release-1.9/monitoring/rest_api.html#jobs-jobid-checkpoints Best, Vino <min....@ubs.com> 于2019年12月2日周一 下午5:01写道： > Hi, > > > > Just wonder how to access the CheckpointStatsCoutns from the main method > of a job? > > > > We need to detect if a job recovers from a checkpoint or starts from an > empty status. > > > > Regards, > > > > Min >
