flink-issues 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:05 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

View raw message