(flink) branch release-2.2 updated: [FLINK-40086][runtime] Adds error handling to newly added preCompletionAction (#28701)

[davidrad]

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

davidradl pushed a commit to branch release-2.2
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-2.2 by this push:
     new c159e421661 [FLINK-40086][runtime] Adds error handling to newly added 
preCompletionAction (#28701)
c159e421661 is described below

commit c159e421661dac7ac9a0e10adf23b90b7c7557b0
Author: Matthias Pohl <map...@apache.org>
AuthorDate: Mon Jul 13 16:19:02 2026 +0200

    [FLINK-40086][runtime] Adds error handling to newly added 
preCompletionAction (#28701)
---
 .../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);