[FLINK-6136] Separate EmbeddedNonHaServices and NonHaServices

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.3.0
• Fix Version/s: 1.3.0
• Component/s: Runtime / Coordination
• Assignee: Till Rohrmann
• Reporter: Till Rohrmann
• Created: 20/Mar/17 17:33
• Updated: 05/May/17 11:50
• Resolved: 05/May/17 11:50

Description

Currently, the NonHaServices and the EmbeddedNonHaServices share the same code base for the JobManager leader election and retrieval. This works if the respective components run in the same process. However, in case of a distributed execution, we have to instantiate StandaloneLeaderRetrieval/ElectionServices to make the leader retrieval possible.

I propose to instantiate the StandaloneLeaderRetrieval/ElectionServices in the NonHaServices implementation and to use them in case of a distributed non-ha execution setting.

Issue Links

• links to: GitHub Pull Request #3622