nicoweidner commented on a change in pull request #17474:
URL: https://github.com/apache/flink/pull/17474#discussion_r734667684
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java
##########
@@ -132,37 +134,49 @@
requestTaskManagerMetricQueryServiceAddresses(@RpcTimeout Time
timeout);
/**
- * Triggers a savepoint with the given savepoint directory as a target.
+ * Triggers a savepoint with the given savepoint directory as a target,
returning a future that
+ * completes when the operation is started.
*
- * @param jobId ID of the job for which the savepoint should be triggered.
- * @param targetDirectory Target directory for the savepoint.
+ * @param operationKey the key of the operation, for deduplication purposes
+ * @param parameters input parameters for taking a savepoint
* @param timeout Timeout for the asynchronous operation
- * @return A future to the {@link CompletedCheckpoint#getExternalPointer()
external pointer} of
- * the savepoint.
+ * @return Future which is completed once the operation is triggered
successfully
*/
- default CompletableFuture<String> triggerSavepoint(
- JobID jobId, String targetDirectory, boolean cancelJob,
@RpcTimeout Time timeout) {
+ default CompletableFuture<Acknowledge> triggerSavepoint(
+ AsynchronousJobOperationKey operationKey,
+ TriggerSavepointParameters parameters,
Review comment:
Ok, I got rid of TriggerSavepointParameters after all, because with
jobId pulled out, it would only wrap 2 properties, which does not make sense
anymore. But please don't ask me to clean the git history for all occurrences
of that class, that could become painful...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
