(flink-agents) 01/03: [fix][runtime] Fix not switch memory context for async action task.

[xtsong]

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

xtsong pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-agents.git

commit 8420160da8b04fede0bbb65fad1cb1e4abcac6fe
Author: WenjinXie <wenjin...@gmail.com>
AuthorDate: Thu Jan 15 14:16:33 2026 +0800

    [fix][runtime] Fix not switch memory context for async action task.
---
 .../apache/flink/agents/runtime/operator/ActionExecutionOperator.java | 4 ----
 1 file changed, 4 deletions(-)

diff --git 
a/runtime/src/main/java/org/apache/flink/agents/runtime/operator/ActionExecutionOperator.java
 
b/runtime/src/main/java/org/apache/flink/agents/runtime/operator/ActionExecutionOperator.java
index 60b7e329..a11efc0e 100644
--- 
a/runtime/src/main/java/org/apache/flink/agents/runtime/operator/ActionExecutionOperator.java
+++ 
b/runtime/src/main/java/org/apache/flink/agents/runtime/operator/ActionExecutionOperator.java
@@ -825,10 +825,6 @@ public class ActionExecutionOperator<IN, OUT> extends 
AbstractStreamOperator<OUT
     }
 
     private void createAndSetRunnerContext(ActionTask actionTask, Object key) {
-        if (actionTask.getRunnerContext() != null) {
-            return;
-        }
-
         RunnerContextImpl runnerContext;
         if (actionTask.action.getExec() instanceof JavaFunction) {
             runnerContext = createOrGetRunnerContext(true);