Affects Version/s: 1.5.1, 1.5.2, 1.6.0
Fix Version/s: None
Component/s: Runtime / REST
Running as a Docker container using the default flink Docker images.
I've been trying to work with the Flink REST API to cancel a running job.
When I deploy a simple job I can retrieve the Job information using the jobs/overview endpoint which returns:
I can also request more information about the job using the jobs/f907f847451cfd9231b7d3c0662b149b endpoint.
According to the documentation, I should be able to do a DELETE request to jobs/f907f847451cfd9231b7d3c0662b149b/cancel. Doing so returns a 404 with the following body:
I also tried a GET request to jobs/f907f847451cfd9231b7d3c0662b149b/cancel-with-savepoint/. That simply returns a 404 without a body.
I tried it with Flink 1.5.1, 1.5.2 and 1.6.0 and get consistent results.
I looked at which API is being used by the Flink web UI when pressing the 'Cancel' button and that one seems to go to jobs/f907f847451cfd9231b7d3c0662b149b/yarn-cancel. If I do a GET request to that one manually it does actually cancel the job.
I've been looking into the Flink source code but couldn't find an immediate clue to what's going on.