[FLINK-4384] Add a "scheduleRunAsync()" feature to the RpcEndpoint

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.2.0
• Component/s: Runtime / Coordination

Environment

FLIP-6 feature branch

• Assignee: Stephan Ewen
• Reporter: Stephan Ewen
• Created: 11/Aug/16 15:31
• Updated: 17/Aug/16 09:59
• Resolved: 13/Aug/16 21:13

Description

It is a common pattern to schedule a call to be executed in the future. Examples are

• delays in retries
• heartbeats,
• checking for heartbeat timeouts

I suggest to add a scheduleRunAsync() method to the RpcEndpoint.

Issue Links

• links to: GitHub Pull Request #2360