[ 
https://issues.apache.org/jira/browse/FLINK-24113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408654#comment-17408654
 ] 

Robert Metzger edited comment on FLINK-24113 at 9/8/21, 7:35 AM:
-----------------------------------------------------------------

[~chesnay] I didn't know this DELETE /cluster REST call.
Given this new information, yes, we just need a flag to disable the shutdown in 
Application Mode.

[~wangyang0918] Just waiting for the result retrieval is not enough. We would 
need an additional REST call confirming that the result has been retrieved and 
persisted in an external system. However, such an option + the additional REST 
calls seem out of scope of the "savepoint" operation.


was (Author: rmetzger):
[~chesnay] I didn't know this DELETE /cluster REST call.
Given this new information, yes, we just need a flag do disable the shutdown in 
Application Mode.

[~wangyang0918] Just waiting for the result retrieval is not enough. We would 
need an additional REST call confirming that the result has been retrieved and 
persisted in an external system. However, such an option + the additional REST 
calls seem out of scope of the "savepoint" operation.

> Introduce option in Application Mode to request cluster shutdown
> ----------------------------------------------------------------
>
>                 Key: FLINK-24113
>                 URL: https://issues.apache.org/jira/browse/FLINK-24113
>             Project: Flink
>          Issue Type: Improvement
>          Components: Runtime / Coordination
>    Affects Versions: 1.15.0
>            Reporter: Robert Metzger
>            Priority: Major
>
> Currently a Flink JobManager started in Application Mode will shut down once 
> the job has completed.
> When doing a "stop with savepoint" operation, we want to keep the JobManager 
> alive after the job has stopped to retrieve and persist the final savepoint 
> location.
> Currently, Flink waits up to 5 minutes and then shuts down.
> I'm proposing to introduce a new configuration flag "application mode 
> shutdown behavior": "keepalive" (naming things is hard ;) ) which will keep 
> the JobManager in ApplicationMode running until a REST call confirms that it 
> can shutdown.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to