[ https://issues.apache.org/jira/browse/FLINK-1958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ufuk Celebi updated FLINK-1958: ------------------------------- Fix Version/s: 0.9 > Improve error handling of receiver task failures > ------------------------------------------------ > > Key: FLINK-1958 > URL: https://issues.apache.org/jira/browse/FLINK-1958 > Project: Flink > Issue Type: Improvement > Components: Distributed Runtime > Affects Versions: master > Reporter: Ufuk Celebi > Fix For: 0.9 > > > Currently, receiver task failures silently fail. > We need the following behaviour: > * Sender keeps going. May be back-pressured when no receiver pulls the data > any more. > * Sender may be cancelled by JobManager > * Partition stays sane > * Netty channel needs to be closed > * Transfer needs to be canceled by a cancel message (receiver to sender) -- This message was sent by Atlassian JIRA (v6.3.4#6332)