Details
-
Improvement
-
Status: Reopened
-
Not a Priority
-
Resolution: Unresolved
-
None
-
None
-
None
Description
UnknownInputChannel basically is a place holder while the producer is unknown which contains some partition parameters to use later for creation of the known channel.
If NettyShuffleEnvironment#updatePartitionInfo provides enough information to add the known channel, one could consider removing UnknownInputChannel and refactoring indexed channel array into a dynamic list.
Initially suggested in https://github.com/apache/flink/pull/8362#discussion_r290308989