[FLINK-11723] Remove KvState related components from NetworkEnvironment

• Type: Sub-task
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Zhijiang
• Reporter: Zhijiang
• Created: 22/Feb/19 06:53
• Updated: 29/Mar/19 09:04
• Resolved: 29/Mar/19 09:04

Description

The NetworkEnvironment would be refactored into NetworkShuffleService created by ShuffleManager future. So the NetworkEnvironment should only cover shuffle related components to make the preparation.

Currently KvStateRegistry, KvStateServer, KvStateClientProxy are not related to shuffle process and mainly used to be got in TaskExecutor. So it is reasonable to remove them from NetworkEnvironment.

And then we could introduce a new KvStateService for wrapping these three components and pass it into TaskManagerService. This new service can also be passed into TaskExecutor, Task for use and avoid spreading in messy.

Issue Links

• links to: GitHub Pull Request #7807