Hi all,
Seems pass in target-directory is a must now for checkpoints REST API, and the
status will not response with save point directory anymore. I can pass in but
the information is redundant with the same already defined in
flink-config.yaml. May I know is there a way to retrieve the save point
directory from flink-config.yaml in flink application? I am not able to get it
from env.getConfig(). Thank you.
________________________________
From: Chesnay Schepler <ches...@apache.org>
Sent: Tuesday, June 19, 2018 11:55 PM
To: user@flink.apache.org
Subject: Re: Questions regarding to Flink 1.5.0 REST API change
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
<wai_...@hotmail.com<mailto:wai_...@hotmail.com>> 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?
* 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?
* previous version:
/jobs/:jobid/cancel-with-savepoint/in-progress/:requestId
Thank you.
Regards,
Yow
