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 >