[flink] branch release-1.14 updated: [FLINK-24647][runtime/coordination] Log thrown exception if UncaughtExceptionHandleMode.LOG is set

[ar...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

arvid pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.14 by this push:
     new b68d189  [FLINK-24647][runtime/coordination] Log thrown exception if UncaughtExceptionHandleMode.LOG is set
b68d189 is described below

commit b68d189cd96896f93ba6401cf0fa9a626ed73ef9
Author: Fabian Paul <fa...@ververica.com>
AuthorDate: Tue Oct 26 12:18:43 2021 +0200

    [FLINK-24647][runtime/coordination] Log thrown exception if UncaughtExceptionHandleMode.LOG is set
---
 .../org/apache/flink/runtime/util/ClusterUncaughtExceptionHandler.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/util/ClusterUncaughtExceptionHandler.java b/flink-runtime/src/main/java/org/apache/flink/runtime/util/ClusterUncaughtExceptionHandler.java
index 6f0cd68..31614d0 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/util/ClusterUncaughtExceptionHandler.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/util/ClusterUncaughtExceptionHandler.java
@@ -45,7 +45,8 @@ public class ClusterUncaughtExceptionHandler implements Thread.UncaughtException
             LOG.error(
                     "WARNING: Thread '{}' produced an uncaught exception. If you want to fail on uncaught exceptions, then configure {} accordingly",
                     t.getName(),
-                    ClusterOptions.UNCAUGHT_EXCEPTION_HANDLING.key());
+                    ClusterOptions.UNCAUGHT_EXCEPTION_HANDLING.key(),
+                    e);
         } else { // by default, fail the job
             FatalExitExceptionHandler.INSTANCE.uncaughtException(t, e);
         }