Can we add an option to allow job cluster mode to start from the latest save point? Otherwise I have to somehow get the info from ZK, before job cluster's container started by K8s.
On Fri, Nov 9, 2018, 01:29 Paul Lam <paullin3...@gmail.com> wrote: > Hi Hao, > > The savepoint path is stored in ZK, but it’s in binary format, so in order > to retrieve the path you have to deserialize it back to some Flink internal > object. > > A better approach would be using REST api to get the path. You could find > it here[1]. > > [1] > https://ci.apache.org/projects/flink/flink-docs-release-1.6/monitoring/rest_api.html > <https://ci.apache.org/projects/flink/flink-docs-release-1.6/monitoring/rest_api.html> > > Best, > Paul Lam > > > 在 2018年11月9日，13:55，Hao Sun <ha...@zendesk.com> 写道： > > Since this save point path is very useful to application updates, where is > this information stored? Can we keep it in ZK or S3 for retrieval? > > <image.png> > > >
