Yuxin Tan created FLINK-35130:
---------------------------------
Summary: Simplify AvailabilityNotifierImpl to support speculative
scheduler and improve performance
Key: FLINK-35130
URL: https://issues.apache.org/jira/browse/FLINK-35130
Project: Flink
Issue Type: Improvement
Components: Runtime / Network
Affects Versions: 1.20.0
Reporter: Yuxin Tan
The AvailabilityNotifierImpl in SingleInputGate has maps storing the channel
ids. But the map key is the result partition id, which will change according to
the different attempt numbers when speculation is enabled. This can be
resolved by using `inputChannels` to get channel and the map key of
inputChannels will not vary with the attempts.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
