[FLINK-14521] CoLocationGroup is not set into JobVertex if the stream node is chained with others

• Type: Bug
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.9.0, 1.9.1
• Component/s: API / DataStream
• Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available
• Assignee: Unassigned
• Reporter: Yun Gao
• Created: 24/Oct/19 11:20
• Updated: 18/Apr/22 10:39

Description

StreamingJobGraphGenerator.isChainable dose not consider the coLocationGroup, if A -> B is chained, the coLocationGroup of the corresponding JobVertex will be set with that of the head node, namely A. Therefore, if B has declared coLocationGroup but A does not, then the coLocationGroup of B will be ignored.

Issue Links

• links to: GitHub Pull Request #10018