[FLINK-11551] Allow RpcEndpoints to execute asynchronous stop operations

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.7.1, 1.8.0
• Fix Version/s: 1.8.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Till Rohrmann
• Reporter: Till Rohrmann
• Created: 07/Feb/19 14:33
• Updated: 12/Feb/19 20:59
• Resolved: 12/Feb/19 20:58

Description

Some RpcEndpoints would benefit from being able to run asynchronous stop operations in the main thread executor. At the moment, this is not possible since RpcEndpoint#postStop is called by by UntypedActor#postStop which is the last call for an actor.

I suggest to introduce a new method RpcEndpoint#onStop which is executed when the RpcEndpoint is requested to terminate. Internally, this method will be called when the UntypedActor is still running, thus, allowing to execute arbitrary other messages (e.g. asynchronous operations in the main thread executor). Only after the future returned by onStop is completed, the underlying UntypedActor will shut down.

Issue Links

• links to: GitHub Pull Request #7665