[FLINK-17180] Implement PipelinedRegion interface for SchedulingTopology

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Gary Yao
• Reporter: Gary Yao
• Created: 16/Apr/20 06:48
• Updated: 30/Jan/21 11:06
• Resolved: 24/Apr/20 13:38

Description

Implement Toplogy#getAllPipelinedRegions() and Topology#getPipelinedRegionOfVertex(ExecutionVertexID) in DefaultExecutionTopology to enable retrieval of pipelined regions.

Issue Links

• is duplicated by: FLINK-16017 Improve attachJobGraph Performance
• links to: GitHub Pull Request #11857