Hi Henry,
What you see in the API documentation is a schema definition and not a
sample
request. The request body should be:
{
"target-directory": "hdfs:///flinkDsl",
"cancel-job": false
}
Let me know if that helps.
Best,
Gary
On Mon, Nov 12, 2018 at 7:15 AM vino yang <yanghua1...@gmail.com> wrote:
> Hi Henry,
>
> Maybe Gary can help you, ping him for you.
>
> Thanks, vino.
>
> 徐涛 <happydexu...@gmail.com> 于2018年11月12日周一 下午12:45写道：
>
>> HI Experts,
>> I am trying to trigger a savepoint from Flink REST API on version 1.6 ,
>> in the document it shows that I need to pass a json as a request body
>> {
>> "type" : "object”,
>> "id" :
>> "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:savepoints:SavepointTriggerRequestBody”,
>> "properties" : {
>> "target-directory" : { "type" : "string" },
>> "cancel-job" : { "type" : "boolean" }
>> }
>> }
>> So I send the following json as
>> {
>> "type":"object”,
>>
>> "id":"urn:jsonschema:org:apache:flink:runtime:rest:messages:job:savepoints:SavepointTriggerRequestBody”,
>> "properties”:{
>> "target-directory":"hdfs:///flinkDsl”,
>> "cancel-job”:false
>> }
>> }
>>
>> And I use okhttp to send the request:
>> val MEDIA_TYPE_JSON = MediaType.parse("application/json; charset=utf-8")
>> val body = RequestBody.create(MEDIA_TYPE_JSON, postBody)
>> val request = new Request.Builder()
>> .url(url)
>> .post(body)
>> .build()
>> client.newCall(request).execute()
>>
>>
>> but get an error {"errors":["Request did not match expected format
>> SavepointTriggerRequestBody.”]}
>> Would anyone give an example of how to invoke the post rest api of Flink?
>> Thanks a lot.
>>
>> Best
>> Henry
>>
>
