[jira] [Created] (FLINK-17047) Simplify SchedulingStrategy#onPartitionConsumable(...) parameters

[Shang Yuanchun (Jira)]

Zhu Zhu created FLINK-17047:
-------------------------------

             Summary: Simplify SchedulingStrategy#onPartitionConsumable(...) parameters
                 Key: FLINK-17047
                 URL: https://issues.apache.org/jira/browse/FLINK-17047
             Project: Flink
          Issue Type: Sub-task
          Components: Runtime / Coordination
    Affects Versions: 1.11.0
            Reporter: Zhu Zhu
             Fix For: 1.11.0


I'd propose to simplify SchedulingStrategy#onPartitionConsumable(...) parameters as below:
1. take IntermediateResultPartitionID instead of ResultPartitionID
    ResultPartitionID is a composition of IntermediateResultPartitionID and ExecutionAttemptID. SchedulingStrategy is not aware of ExecutionAttemptID so there is no need to expose it.
2. drop the executionVertexId param. executionVertexId does not provide extra information. The check in LazyFromSourcesSchedulingStrategy does not make much sense since the executionVertexId is just retrieved by the partitionId in an earlier stage. It makes things more complex since a blocking result partition can become consumable when a vertex who is not its producer finishes.

This simplification also eases the work of FLINK-14234.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)