Zhijiang created FLINK-16285: -------------------------------- Summary: 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
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)