Hi, You could trigger savepoint via rest API [1] or refer to SavepointITCase[2] to see how to trigger savepoint in test code.
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/ops/rest_api/#jobs-jobid-savepoints [2] https://github.com/apache/flink/blob/c688bf3c83e72155ccf5d04fe397b7c0a1274fd1/flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointITCase.java#L438 Best Yun Tang ________________________________ From: Abdullah bin Omar <abdullahbinoma...@gmail.com> Sent: Tuesday, May 4, 2021 11:50 To: user@flink.apache.org <user@flink.apache.org> Subject: savepoint command in code Hello, I am trying to use the savepoint command (./bin/flink savepoint jobid) in the code instead of doing it manually in the terminal. The jobid can get using getjobid(). The problem is to define the path ./bin/flink — it can not be shown as a directory (probably because of a unix executable file). Is there a way to define the path (./bin/flink) in the code? or, is there any function to get the savepoint from code instead of manual command? Thank you
