flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-1543) Proper exception handling in actors
Date Fri, 13 Feb 2015 17:54:11 GMT

    [ https://issues.apache.org/jira/browse/FLINK-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14320451#comment-14320451

ASF GitHub Bot commented on FLINK-1543:

GitHub user tillrohrmann opened a pull request:


    [FLINK-1543] Adds better exception handling in actors

    Adds try and catch blocks around exception throwing methods in the JobManager and TaskManager.
This PR is based on #384.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/tillrohrmann/flink akkaExceptions

Alternatively you can review and apply these changes as the patch at:


To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #394
commit bfeac6becc00f3bb02379ff448aefab95548082c
Author: Till Rohrmann <trohrmann@apache.org>
Date:   2015-02-10T11:21:33Z

    [FLINK-1508] [runtime] Removes AkkaUtil.ask and replaces respective calls with explicit
future handling.
    Removes blocking calls for ActorRef retrieval in actors.
    This closes #384.

commit 86976bb0feab8abb43ab302a61294157cd1fe35a
Author: Till Rohrmann <trohrmann@apache.org>
Date:   2015-02-12T10:49:09Z

    [FLINK-1543] [runtime] Adds try and catch blocks around all method calls from an actor's
receive method which can throw an exception. Sets the StoppingSupervisorStrategy as default
for all guardians.
    This closes #394.


> Proper exception handling in actors
> -----------------------------------
>                 Key: FLINK-1543
>                 URL: https://issues.apache.org/jira/browse/FLINK-1543
>             Project: Flink
>          Issue Type: Improvement
>            Reporter: Till Rohrmann
> With Akka's actors it is important to not throw exceptions in the actor thread, if one
does not want that the actor restarts or stops. Many of the Java components which are called
from the actor's receive method throw exceptions which are not properly handled by the actor
thread. Therefore, we have to catch these exceptions and handle them properly. 

This message was sent by Atlassian JIRA

View raw message