[FLINK-3969] Log Exceptions by Invokable

This closes apache#2091
kongxi · Jun 15, 2016 · 279777f · 279777f
1 parent c8fed99
commit 279777f
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -638,6 +638,7 @@ else if (current == ExecutionState.CANCELING) {
  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();