Zhu Zhu created FLINK-20439:
-------------------------------
Summary: Consider simplifying or removing mechanism to
scheduleOrUpdateConsumers
Key: FLINK-20439
URL: https://issues.apache.org/jira/browse/FLINK-20439
Project: Flink
Issue Type: Sub-task
Components: Runtime / Coordination
Reporter: Zhu Zhu
Fix For: 1.13.0
Execution#scheduleOrUpdateConsumers() was used for multiple purposes:
- schedule a vertex when its PIPELINED inputs have produced data
- schedule a vertex when its BLOCKING inputs have finished
- update consumed partition info to RUNNING consumers
- cache consumed partition info for DEPLOYING consumers
It is not needed anymore in the latest pipelined region scheduling because
- a region will be scheduled only when all its upstream regions have finished
- a vertex will always know all its consumed partitions when scheduled
So we can consider how to simply or remove it, which also involves things like
UnknownInputChannel, ResultPartitionConsumableNotifier,
Execution#cachePartitionInfo(), etc.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
