GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/2626
[FLINK-4787] [runtime-web] Expose cancel-with-savepoint via REST API
Follow up to #2609, exposing the cancel-with-savepoint command via the REST
API. The relevant commits are the last two ones.
The `RequestHandler` now returns a generic `HttpResponse` instead of a
`String`. This enables handlers to return custom reponses (different http
codes, etc.). Now most handlers extend thee `AbstractJsonRequestHandler` for
default JSON responses (which used to be handled by the generic
`RequestHandler`).
Adds handlers for triggering and monitoring a job cancellation with
savepoints. Since this operation can take some time, we do this asynchronously.
According to various online resources, the way to go for REST APIs in such
cases is to return HTTP 201 accepted with the location of the in-progress
operation.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/uce/flink 4787-cancel_with_savepoint_rest_api
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2626.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2626
----
commit 99a9621383e6a223e39e4ec22d60671a205d958d
Author: Ufuk Celebi <u...@apache.org>
Date: 2016-10-06T14:43:42Z
[FLINK-4512] [FLIP-10] Add option to persist periodic checkpoints
[FLINK-4509] [FLIP-10] Specify savepoint directory per savepoint
[FLINK-4507] [FLIP-10] Deprecate savepoint backend config
commit 25ffc04d7e5d7ef9538447ee5162c0d203e96e89
Author: Ufuk Celebi <u...@apache.org>
Date: 2016-10-07T09:48:47Z
[FLINK-4717] Add CancelJobWithSavepoint
- Adds CancelJobWithSavepoint message, which triggers a savepoint
before cancelling the respective job.
- Adds -s [targetDirectory] option to CLI cancel command:
* bin/flink cancel <jobID> (regular cancelling)
* bin/flink cancel -s <jobID> (cancel with savepoint to default dir)
* bin/flink cancek -s <targetDir> <jobID> (cancel with savepoint to
targetDir)
commit bc88dba90a263e80691448e20644e5f126551bb6
Author: Ufuk Celebi <u...@apache.org>
Date: 2016-10-11T08:08:14Z
[FLINK-4787] [runtime-web] Return generic HttpResponse in RequestHandler
- Let RequestHandler return a generic HttpResponse instead of a String. This
enables handlers to return custom reponses (differnt http codes, etc.)
- Introduce AbstractJsonRequestHandler for default JSON responses
commit ecbcf46f5a9d874dbdd908d48c7035c1cb338c1a
Author: Ufuk Celebi <u...@apache.org>
Date: 2016-10-11T08:09:20Z
[FLINK-4787] [runtime-web] Add JobCancellationWithSavepointHandlers
- Add handlers for triggering and monitoring job cancellation with
savepoints.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
