From 1e404d5d50fa52eedf0293e372688cbe7aa454a7 Mon Sep 17 00:00:00 2001 From: zentol Date: Fri, 10 Jun 2016 16:43:33 +0200 Subject: [PATCH] [FLINK-3969] Log Exceptions by Invokable --- .../src/main/java/org/apache/flink/runtime/taskmanager/Task.java | 1 + 1 file changed, 1 insertion(+) 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 1f766e187e2a7..31bec2579ef08 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 @@ 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();