[flink] 02/11: [hotfix][checkpointing] Beautify stack trace by stripping wrapping CompletionExceptions

[sewen]

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

sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 1af33f1285d557f0171f4587d7f4e789df27e7cb
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();