[FLINK-20716] Pluggable shuffle service public interface IndexedInputGate mixed with Netty shuffle service implementation.

• Type: Sub-task
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Runtime / Coordination
• Labels: auto-deprioritized-major
• Assignee: Unassigned
• Reporter: Jin Xing
• Created: 22/Dec/20 11:12
• Updated: 02/Aug/21 09:51

Description

In current "pluggable shuffle service", IndexedInputGate defines the reading for a single intermediate result (doc of InputGate) and InputChannel defines a single reading channel in IndexedInputGate. IndexedInputGate consists of a number of InputChanels. Current fields of InputChannel are mainly some descriptions or metrics for a single channel. But we found SingleInputGate is mixed in. From our understanding, SingleInputGate is a specific implementation in "Netty shuffle service" and should not be exposed by "pluggable shuffle service".