Ufuk Celebi created FLINK-1957: ---------------------------------- Summary: Improve error handling of transport failures Key: FLINK-1957 URL: https://issues.apache.org/jira/browse/FLINK-1957 Project: Flink Issue Type: Improvement Components: Distributed Runtime Affects Versions: master Reporter: Ufuk Celebi
Currently, transport failures fail the receiver silently w/o proper error attribution to the transport. We want the following behaviour: * Attributed to the receiver * Receiver fails with an Exception * Subpartition on the sender side stays sane * Netty channel needs to be closed (as result of transport error) and data transfer aborted -- This message was sent by Atlassian JIRA (v6.3.4#6332)