GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/449
Streaming cancellation + exception handling rework
This PR reworks the way runtime exceptions are handled in the streaming
runtime.
User code and other types of exceptions thrown during the invocation are
now properly propagated.
This PR also introduces proper cancellation for streaminvokables with
extending the Source and SinkFunction interfaces with a cancel method.
Some sources which maintain connections are also reworked to close the
connections in any case.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mbalassi/flink FLINK-1625
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/449.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 #449
----
commit e3b26bebe4c9c42790d8f1a30573cbfaf493a45c
Author: Gyula Fora <[email protected]>
Date: 2015-03-03T10:49:37Z
[FLINK-1625] [streaming] Refactored StreamVertex and subclasses to clean up
after invoke and properly log and propagate exceptions
commit 93fb55670523bc52891395c4a32d3bbadf38811f
Author: Gyula Fora <[email protected]>
Date: 2015-03-03T13:43:33Z
[FLINK-1625] [streaming] Added proper cancellation to StreamInvokables +
Sink- and SourceFunction interfaces extended with cancel method
----
---
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 [email protected] or file a JIRA ticket
with INFRA.
---
