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 <trohrm...@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 <trohrm...@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.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
