This is an automated email from the ASF dual-hosted git repository. XComp pushed a commit to branch FLINK-40086 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 967a4a135e635c58b61918963daf134804af80b2 Author: Matthias Pohl <[email protected]> AuthorDate: Thu Jul 9 16:38:01 2026 +0200 [FLINK-40086][runtime] Adds error handling to newly added preCompletionAction --- .../java/org/apache/flink/runtime/executiongraph/Execution.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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 a704e3290fd..430cd9ee76d 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 @@ -1708,7 +1708,11 @@ public class Execution 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);
