Re: savepoint command in code

2021-05-05 Thread Yun Tang
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/c688bf3c83e72155ccf5

Re: savepoint command in code

2021-05-03 Thread Matthias Pohl
Hi Abdullah, is there a reason you're not considering triggering the stop-with-savepoint operation through the REST API [1]? I'm not entirely sure whether I understand you correctly: ./bin/flink is an executable. Why Would you assume it to be shown as a directory? You would need to provide FLINK_HO