Andrey Zagrebin created FLINK-12203:
---------------------------------------
Summary: Refactor ResultPartitionManager to break tie with Task
Key: FLINK-12203
URL: https://issues.apache.org/jira/browse/FLINK-12203
Project: Flink
Issue Type: Sub-task
Reporter: Andrey Zagrebin
At the moment, we have ResultPartitionManager.releasePartitionsProducedBy which
uses indexing by task in network environment. These methods are eventually used
only by Task which already knows its partitions so Task and TE.failPartition
could directly use NetworkEnviroment.releasePartition(ResultPartitionID). This
also requires that JM Execution sends produced partition ids instead of just
ExecutionAttemptID.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
