Re: Questions regarding to Flink 1.5.0 REST API change

2018-06-21 Thread Siew Wai Yow
hesnay Schepler Sent: Thursday, June 21, 2018 3:36 PM To: user@flink.apache.org Subject: Re: Questions regarding to Flink 1.5.0 REST API change If you could open a JIRA this would be great. On 21.06.2018 09:07, sihua zhou wrote: Hi Yow, I had a look at the related code, I think this seems like

Re: Questions regarding to Flink 1.5.0 REST API change

2018-06-21 Thread Chesnay Schepler
ne 19, 2018 11:55 PM *To:* user@flink.apache.org <mailto: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/s

Re: Questions regarding to Flink 1.5.0 REST API change

2018-06-21 Thread sihua zhou
end.async: true state.checkpoints.num-retained: 5 state.savepoints.dir: hdfs://192.168.56.150:8020/flink/savepoints -Yow From: Chesnay Schepler Sent: Wednesday, June 20, 2018 3:15 PM To:user@flink.apache.org Subject: Re: Questions regarding to Flink 1.5.0 REST API change I think you can

Re: Questions regarding to Flink 1.5.0 REST API change

2018-06-21 Thread sihua zhou
ate.backend.async: true state.checkpoints.num-retained: 5 state.savepoints.dir: hdfs://192.168.56.150:8020/flink/savepoints -Yow From: Chesnay Schepler Sent: Wednesday, June 20, 2018 3:15 PM To:user@flink.apache.org Subject: Re: Questions regarding to Flink 1.5.0 REST API change I think you can set the t

Re: Questions regarding to Flink 1.5.0 REST API change

2018-06-21 Thread Chesnay Schepler
vepoints -Yow *From:* Chesnay Schepler *Sent:* Wednesday, June 20, 2018 3:15 PM *To:* user@flink.apache.org *Subject:* Re: Questions regarding to Flink 1.5.0 REST API change I think you can set the target-directory to null. But I'

Re: Questions regarding to Flink 1.5.0 REST API change

2018-06-20 Thread Siew Wai Yow
ts -Yow From: Chesnay Schepler Sent: Wednesday, June 20, 2018 3:15 PM To: user@flink.apache.org Subject: Re: Questions regarding to Flink 1.5.0 REST API change I think you can set the target-directory to null. But I'm not sure why this particular reques

Re: Questions regarding to Flink 1.5.0 REST API change

2018-06-20 Thread Chesnay Schepler
le to get it from env.getConfig(). Thank you. *From:* Chesnay Schepler *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/:

Re: Questions regarding to Flink 1.5.0 REST API change

2018-06-19 Thread Siew Wai Yow
point directory from flink-config.yaml in flink application? I am not able to get it from env.getConfig(). Thank you. From: Chesnay Schepler Sent: Tuesday, June 19, 2018 11:55 PM To: user@flink.apache.org Subject: Re: Questions regarding to Flink 1.5.0 REST API

Re: Questions regarding to Flink 1.5.0 REST API change

2018-06-19 Thread Siew Wai Yow
Thank you @Chesnay Schepler<mailto:ches...@apache.org> and @Esteban Serrano<mailto:st96d...@gmail.com>! From: Chesnay Schepler Sent: Tuesday, June 19, 2018 11:55 PM To: user@flink.apache.org Subject: Re: Questions regarding to Flink 1.5.0 REST A

Re: Questions regarding to Flink 1.5.0 REST API change

2018-06-19 Thread Chesnay Schepler
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

Re: Questions regarding to Flink 1.5.0 REST API change

2018-06-19 Thread Esteban Serrano
For #1, you need to use a PATCH request to "*/jobs/:jobid*" On Tue, Jun 19, 2018 at 11:35 AM Siew Wai Yow 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.* >

Questions regarding to Flink 1.5.0 REST API change

2018-06-19 Thread Siew Wai Yow
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