You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2016/06/15 11:46:48 UTC
flink git commit: [FLINK-3969] Log Exceptions by Invokable
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 <ch...@apache.org>
Authored: Fri Jun 10 16:43:33 2016 +0200
Committer: zentol <ch...@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();