Apache Flink - Error on creating savepoints using REST interface

[M Singh]

Hi:

I am using Flink 1.6.2 and trying to create a savepoint using the following curl command using the following references (https://ci.apache.org/projects/flink/flink-docs-release-1.6/monitoring/rest_api.html) and https://ci.apache.org/projects/flink/flink-docs-release-1.6/api/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlers.html

curl -v -H "Content-Type: application/json" -XPOST http://<jobnamager:port>/jobs/<jobId>/savepoints -d '{"target-directory":"s3://mys3bucket/savepointdirectory/testMay22-sp1/"}'
 

But I am getting the following error:

{"errors":["Request did not match expected format SavepointTriggerRequestBody."]}


Can you please let me know what I could be missing ?

Thanks

[Chesnay Schepler]

You also have to set the boolean cancel-job parameter.

On 22/05/2020 22:47, M Singh wrote:

Hi:

I am using Flink 1.6.2 and trying to create a savepoint using the following curl command using the following references (https://ci.apache.org/projects/flink/flink-docs-release-1.6/monitoring/rest_api.html) and https://ci.apache.org/projects/flink/flink-docs-release-1.6/api/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlers.html

curl -v -H "Content-Type: application/json" -XPOST http://<jobnamager:port>/jobs/<jobId>/savepoints -d '{"target-directory":"s3://mys3bucket/savepointdirectory/testMay22-sp1/"}'
 

But I am getting the following error:

{"errors":["Request did not match expected format SavepointTriggerRequestBody."]}


Can you please let me know what I could be missing ?

Thanks

[M Singh]

Hi Chesney:

The SavepointTriggerRequestBody indicates defaultValue for cancel-job attribute, so is it not being honored ?

https://github.com/apache/flink/blob/release-1.6/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/savepoints/SavepointTriggerRequestBody.java

Thanks

On Saturday, May 23, 2020, 10:17:27 AM EDT, Chesnay Schepler <[hidden email]> wrote:

You also have to set the boolean cancel-job parameter.

On 22/05/2020 22:47, M Singh wrote:

Hi:

I am using Flink 1.6.2 and trying to create a savepoint using the following curl command using the following references (https://ci.apache.org/projects/flink/flink-docs-release-1.6/monitoring/rest_api.html) and https://ci.apache.org/projects/flink/flink-docs-release-1.6/api/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlers.html

curl -v -H "Content-Type: application/json" -XPOST http://<jobnamager:port>/jobs/<jobId>/savepoints -d '{"target-directory":"s3://mys3bucket/savepointdirectory/testMay22-sp1/"}'

 

But I am getting the following error:

{"errors":["Request did not match expected format SavepointTriggerRequestBody."]}

Can you please let me know what I could be missing ?

Thanks