This is an automated email from the ASF dual-hosted git repository. sxnan pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-agents.git
commit 520c013d01b3968d4d409917a6b78ec26fad3b39 Author: chouc <[email protected]> AuthorDate: Fri Jan 23 23:44:42 2026 +0800 [fix] Fixed the DurableExecutionException error that could not be serialized. --- .../org/apache/flink/agents/runtime/context/RunnerContextImpl.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/runtime/src/main/java/org/apache/flink/agents/runtime/context/RunnerContextImpl.java b/runtime/src/main/java/org/apache/flink/agents/runtime/context/RunnerContextImpl.java index 01b6e4c4..cab790dc 100644 --- a/runtime/src/main/java/org/apache/flink/agents/runtime/context/RunnerContextImpl.java +++ b/runtime/src/main/java/org/apache/flink/agents/runtime/context/RunnerContextImpl.java @@ -17,6 +17,7 @@ */ package org.apache.flink.agents.runtime.context; +import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.flink.agents.api.Event; @@ -359,7 +360,13 @@ public class RunnerContextImpl implements RunnerContext { /** Serializable exception info for durable execution persistence. */ public static class DurableExecutionException { + private static final String FIELD_MESSAGE = "message"; + private static final String FIELD_EXCEPTION_CLASS = "exceptionClass"; + + @JsonProperty(FIELD_EXCEPTION_CLASS) private final String exceptionClass; + + @JsonProperty(FIELD_MESSAGE) private final String message; public DurableExecutionException() {
