flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ufuk Celebi (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-1955) Improve error handling of sender task failures
Date Wed, 29 Apr 2015 10:30:06 GMT
Ufuk Celebi created FLINK-1955:
----------------------------------

             Summary: Improve error handling of sender task failures
                 Key: FLINK-1955
                 URL: https://issues.apache.org/jira/browse/FLINK-1955
             Project: Flink
          Issue Type: Improvement
          Components: Distributed Runtime
    Affects Versions: master
            Reporter: Ufuk Celebi


Currently, if a sender task fails, the produced partition is silently released.

We want:
* Produced result partition becomes erroneous with a SenderFailedException
* Receiver cancels itself when encountering the SenderFailedException
* May also be cancelled by the JobManager (if that call is faster than the detection of the
failed sender)
* This closes the Netty channel



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message