You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/04/15 15:49:00 UTC

[jira] [Created] (FLINK-12203) Refactor ResultPartitionManager to break tie with Task

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)