Repository: flink Updated Branches: refs/heads/master c8fed99e3 -> 279777f2f
[FLINK-3969] Log Exceptions by Invokable This closes #2091 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/279777f2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/279777f2 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/279777f2 Branch: refs/heads/master Commit: 279777f2f265405236bf3b4ab7b974e80f84a4ed Parents: c8fed99 Author: zentol <ches...@apache.org> Authored: Fri Jun 10 16:43:33 2016 +0200 Committer: zentol <ches...@apache.org> Committed: Wed Jun 15 13:45:36 2016 +0200 ---------------------------------------------------------------------- .../src/main/java/org/apache/flink/runtime/taskmanager/Task.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/279777f2/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java index 548d7d0..1746f2c 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java @@ -638,6 +638,7 @@ public class Task implements Runnable { else { if (STATE_UPDATER.compareAndSet(this, current, ExecutionState.FAILED)) { // proper failure of the task. record the exception as the root cause + LOG.error("Task execution failed. ", t); failureCause = t; cancelInvokable();
