This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 8ceb89b5784a24c9938c8b28974bad4b17c6ccdd Author: Stephan Ewen <se...@apache.org> AuthorDate: Fri May 29 11:13:34 2020 +0200 [hotfix][checkpointing] Beautify stack trace by stripping wrapping CompletionExceptions --- .../org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java index 7689f29..b283a2a 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java @@ -773,6 +773,9 @@ public class CheckpointCoordinator { * @param throwable the reason of trigger failure */ private void onTriggerFailure(@Nullable PendingCheckpoint checkpoint, Throwable throwable) { + // beautify the stack trace a bit + throwable = ExceptionUtils.stripCompletionException(throwable); + try { if (checkpoint != null && !checkpoint.isDiscarded()) { int numUnsuccessful = numUnsuccessfulCheckpointsTriggers.incrementAndGet();