Re: savepoint command in code

2021-05-05 Thread Yun Tang
/c688bf3c83e72155ccf5d04fe397b7c0a1274fd1/flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointITCase.java#L438 Best Yun Tang From: Abdullah bin Omar Sent: Tuesday, May 4, 2021 11:50 To: user@flink.apache.org Subject: savepoint command in code Hello, I am trying

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

savepoint command in code

2021-05-03 Thread Abdullah bin Omar
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 fi