[hotfix][checkpointing] Beautify stack trace by stripping wrapping Co…

…mpletionExceptions
zhaohaolin · May 30, 2020 · 1af33f1 · 1af33f1
1 parent b66d16f
commit 1af33f1
Showing 1 changed file with 3 additions and 0 deletions.
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
@@ -773,6 +773,9 @@ private void onTriggerFailure(
 	 * @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();