diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java index 872732db36d9d3..9f9077d26684cd 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java @@ -1537,7 +1537,11 @@ private boolean transitionState( initializingOrRunningFuture.complete(null); } else if (targetState.isTerminal()) { if (preCompletionAction != null) { - preCompletionAction.run(); + try { + preCompletionAction.run(); + } catch (Exception e) { + LOG.error("Error while executing pre-completion action.", e); + } } // complete the terminal state future terminalStateFuture.complete(targetState);