[ https://issues.apache.org/jira/browse/FLINK-12203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16829273#comment-16829273 ]
Andrey Zagrebin commented on FLINK-12203: ----------------------------------------- Hey [~rmetzger], thanks for correction. I will try to keep components up to date. > 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 > Components: Runtime / Network > Reporter: Andrey Zagrebin > Assignee: Andrey Zagrebin > Priority: Major > Labels: pull-request-available > Time Spent: 10m > Remaining Estimate: 0h > > 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 can > use ResultPartition.fail(cause) and TaskExecutor.failPartition could directly > use NetworkEnviroment.releasePartitions(Collection<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)