You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/13 18:54:11 UTC

[jira] [Commented] (FLINK-1543) Proper exception handling in actors

    [ 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:

    https://github.com/apache/flink/pull/394

    [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:

    https://github.com/apache/flink/pull/394.patch

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 <tr...@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 <tr...@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
(v6.3.4#6332)