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

Reply via email to