[jira] [Created] (FLINK-12960) Move ResultPartitionDeploymentDescriptor#releasedOnConsumption to PartitionDescriptor#releasedOnConsumption

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-12960) Move ResultPartitionDeploymentDescriptor#releasedOnConsumption to PartitionDescriptor#releasedOnConsumption

Shang Yuanchun (Jira)
Andrey Zagrebin created FLINK-12960:
---------------------------------------

             Summary: Move ResultPartitionDeploymentDescriptor#releasedOnConsumption to PartitionDescriptor#releasedOnConsumption
                 Key: FLINK-12960
                 URL: https://issues.apache.org/jira/browse/FLINK-12960
             Project: Flink
          Issue Type: Sub-task
          Components: Runtime / Coordination
            Reporter: Andrey Zagrebin
            Assignee: Andrey Zagrebin
             Fix For: 1.9.0


ResultPartitionDeploymentDescriptor#releasedOnConsumption shows the intention how the partition is going to be used by the shuffle user. If it is not supported by the shuffle service for a certain type of partition, ShuffleMaster#registerPartitionWithProducer and ShuffleEnvironment#createResultPartitionWriters should throw an exception. ShuffleMaster#registerPartitionWithProducer takes PartitionDescriptor. ResultPartitionDeploymentDescriptor#releasedOnConsumption should be part of PartitionDescriptor so that not only ShuffleEnvironment but also ShuffleMaster is already aware about releasedOnConsumption.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)