[FLINK-12706] Introduce ShuffleService interface and its configuration

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Done
• Fix Version/s: 1.9.0
• Component/s: Runtime / Configuration, Runtime / Coordination, Runtime / Network
• Labels: pull-request-available
• Assignee: Andrey Zagrebin
• Reporter: Andrey Zagrebin
• Created: 03/Jun/19 08:24
• Updated: 20/Jun/19 17:22
• Resolved: 20/Jun/19 17:21

Description

ShuffleService should be a factory for ShuffleMaster in JM and local ShuffleEnvironment in TM. The default implementation is already available former NetworkEnvironment. To make it pluggable, we need to provide a service loading for the configured ShuffleService implementation class in Flink configuration.

Issue Links

• links to: GitHub Pull Request #8680