[ https://issues.apache.org/jira/browse/FLINK-31681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Piotr Nowojski updated FLINK-31681: ----------------------------------- Affects Version/s: 1.15.1 > Network connection timeout between operators should trigger either network > re-connection or job failover > -------------------------------------------------------------------------------------------------------- > > Key: FLINK-31681 > URL: https://issues.apache.org/jira/browse/FLINK-31681 > Project: Flink > Issue Type: Bug > Affects Versions: 1.15.1 > Reporter: Dong Lin > Priority: Major > > If a network connection error occurs between two operators, the upstream > operator may log the following error message in the method > PartitionRequestQueue#handleException and subsequently close the connection. > When this happens, the Flink job may become stuck without completing or > failing. > To avoid this issue, we can either allow the upstream operator to reconnect > with the downstream operator, or enable job failover so that users can take > corrective action promptly. > org.apache.flink.runtime.io.network.netty.PartitionRequestQueue - Encountered > error while consuming partitions > org.apache.flink.shaded.netty4.io.netty.channel.unix.Errors#NativeIOException: > writeAccess(...) failed: Connection timed out. -- This message was sent by Atlassian Jira (v8.20.10#820010)