[ https://issues.apache.org/jira/browse/FLINK-16285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Zhijiang updated FLINK-16285: ----------------------------- Fix Version/s: 1.11.0 > Refactor SingleInputGate#setInputChannel to remove > IntermediateResultPartitionID argument > ----------------------------------------------------------------------------------------- > > Key: FLINK-16285 > URL: https://issues.apache.org/jira/browse/FLINK-16285 > Project: Flink > Issue Type: Improvement > Components: Runtime / Network > Reporter: Zhijiang > Assignee: Zhijiang > Priority: Minor > Labels: pull-request-available > Fix For: 1.11.0 > > Time Spent: 10m > Remaining Estimate: 0h > > The IntermediateResultPartitionID info can be got directly from the > respective InputChannel, so we can remove it fromĀ the arguments of > SingleInputGate#setInputChannel to cleanup the codes. > It is also helpful to simplify the unit tests and avoid passing the > inconsistent IntermediateResultPartitionID with theĀ internal > ResultPartitionID that the respective InputChannel maintains. -- This message was sent by Atlassian Jira (v8.3.4#803005)