Repository: flink Updated Branches: refs/heads/master 34a42681d -> ede7fdc4a
Add JavaDoc to StreamTask.checkTimerException to clarify what it does Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ede7fdc4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ede7fdc4 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ede7fdc4 Branch: refs/heads/master Commit: ede7fdc4a733e347becdb9811539e066c30a6e86 Parents: 34a4268 Author: Aljoscha Krettek <[email protected]> Authored: Tue Mar 22 11:33:43 2016 +0100 Committer: Aljoscha Krettek <[email protected]> Committed: Tue Mar 22 11:33:43 2016 +0100 ---------------------------------------------------------------------- .../flink/streaming/runtime/tasks/StreamTask.java | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/ede7fdc4/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java index 7138d53..7b154cd 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java @@ -671,8 +671,16 @@ public abstract class StreamTask<OUT, Operator extends StreamOperator<OUT>> delay, TimeUnit.MILLISECONDS); } - - public void checkTimerException() throws TimerException { + + /** + * Check whether an exception was thrown in a Thread other than the main Thread. (For example + * in the processing-time trigger Thread). This will rethrow that exception in case on + * occured. + * + * <p>This must be called in the main loop of {@code StreamTask} subclasses to ensure + * that we propagate failures. + */ + public void checkTimerException() throws AsynchronousException { if (asyncException != null) { throw asyncException; }
