1. PATCH to /jobs/:jobid, you can specify CANCEL/STOP with the "mode"
query parameter
2. POST to /jobs/:jobid/savepoints, with a json payload. Returns a
trigger id, used for 3).
{|
"target-directory" : { |
|"type" : "string" }, "cancel-job" : { "type" : "boolean" } } |
3. GET to /jobs/:jobid/savepoints/:triggerid
On 19.06.2018 17:40, Esteban Serrano wrote:
For #1, you need to use a PATCH request to "*/jobs/:jobid*"
On Tue, Jun 19, 2018 at 11:35 AM Siew Wai Yow <[email protected]
<mailto:[email protected]>> wrote:
Hi,
Regarding to Flink 1.5.0 REST API breaking change,
* /The REST API to cancel a job was changed./
* /The REST API to cancel a job with savepoint was changed./
I have few dump questions,
1. Any replacement for cancellation ONLY without save-point? Only
found "*/jobs/:jobid/savepoints*".
2. For "*/jobs/:jobid/savepoints*", how could I form the URL with
cancellation and with directory afterward?
1. http://192.168.56.151:8081/jobs/<jobid>/savepoints/cancel-job/true??
3. Any cancellation progress monitoring in 1.5 like previous
version 1.3/1.4?
1. previous version:
/jobs/:jobid/cancel-with-savepoint/in-progress/:requestId
Thank you.
Regards,
Yow
