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 7ca61559566a52e59ccd9710750c23b0a88a2aca Author: WenjinXie <[email protected]> AuthorDate: Wed Sep 17 18:20:06 2025 +0800 [hotifx] Relocate Action class. fix Action location. --- plan/src/main/java/org/apache/flink/agents/plan/AgentPlan.java | 1 + .../main/java/org/apache/flink/agents/plan/{ => actions}/Action.java | 3 ++- .../apache/flink/agents/plan/serializer/ActionJsonDeserializer.java | 2 +- .../org/apache/flink/agents/plan/serializer/ActionJsonSerializer.java | 2 +- .../apache/flink/agents/plan/serializer/AgentPlanJsonDeserializer.java | 2 +- .../apache/flink/agents/plan/serializer/AgentPlanJsonSerializer.java | 2 +- plan/src/test/java/org/apache/flink/agents/plan/AgentPlanTest.java | 1 + plan/src/test/java/org/apache/flink/agents/plan/TestAction.java | 1 + .../flink/agents/plan/compatibility/CreateJavaAgentPlanFromJson.java | 2 +- .../flink/agents/plan/serializer/ActionJsonDeserializerTest.java | 2 +- .../apache/flink/agents/plan/serializer/ActionJsonSerializerTest.java | 2 +- .../flink/agents/plan/serializer/AgentPlanJsonDeserializerTest.java | 2 +- .../flink/agents/plan/serializer/AgentPlanJsonSerializerTest.java | 2 +- .../org/apache/flink/agents/runtime/actionstate/ActionStateStore.java | 2 +- .../org/apache/flink/agents/runtime/actionstate/ActionStateUtil.java | 2 +- .../apache/flink/agents/runtime/actionstate/KafkaActionStateStore.java | 2 +- .../apache/flink/agents/runtime/operator/ActionExecutionOperator.java | 2 +- .../main/java/org/apache/flink/agents/runtime/operator/ActionTask.java | 2 +- .../java/org/apache/flink/agents/runtime/operator/JavaActionTask.java | 2 +- .../apache/flink/agents/runtime/python/operator/PythonActionTask.java | 2 +- .../agents/runtime/python/operator/PythonGeneratorActionTask.java | 2 +- .../apache/flink/agents/runtime/actionstate/ActionStateUtilTest.java | 2 +- .../flink/agents/runtime/actionstate/InMemoryActionStateStore.java | 2 +- .../flink/agents/runtime/operator/ActionExecutionOperatorTest.java | 2 +- 24 files changed, 25 insertions(+), 21 deletions(-) diff --git a/plan/src/main/java/org/apache/flink/agents/plan/AgentPlan.java b/plan/src/main/java/org/apache/flink/agents/plan/AgentPlan.java index 8ef8b9e..ade3347 100644 --- a/plan/src/main/java/org/apache/flink/agents/plan/AgentPlan.java +++ b/plan/src/main/java/org/apache/flink/agents/plan/AgentPlan.java @@ -29,6 +29,7 @@ import org.apache.flink.agents.api.resource.ResourceDescriptor; import org.apache.flink.agents.api.resource.ResourceType; import org.apache.flink.agents.api.resource.SerializableResource; import org.apache.flink.agents.api.tools.ToolMetadata; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.agents.plan.resourceprovider.JavaResourceProvider; import org.apache.flink.agents.plan.resourceprovider.JavaSerializableResourceProvider; import org.apache.flink.agents.plan.resourceprovider.ResourceProvider; diff --git a/plan/src/main/java/org/apache/flink/agents/plan/Action.java b/plan/src/main/java/org/apache/flink/agents/plan/actions/Action.java similarity index 96% rename from plan/src/main/java/org/apache/flink/agents/plan/Action.java rename to plan/src/main/java/org/apache/flink/agents/plan/actions/Action.java index 010bedd..a9a4cfa 100644 --- a/plan/src/main/java/org/apache/flink/agents/plan/Action.java +++ b/plan/src/main/java/org/apache/flink/agents/plan/actions/Action.java @@ -16,10 +16,11 @@ * limitations under the License. */ -package org.apache.flink.agents.plan; +package org.apache.flink.agents.plan.actions; import org.apache.flink.agents.api.Event; import org.apache.flink.agents.api.context.RunnerContext; +import org.apache.flink.agents.plan.Function; import org.apache.flink.agents.plan.serializer.ActionJsonDeserializer; import org.apache.flink.agents.plan.serializer.ActionJsonSerializer; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.annotation.JsonDeserialize; diff --git a/plan/src/main/java/org/apache/flink/agents/plan/serializer/ActionJsonDeserializer.java b/plan/src/main/java/org/apache/flink/agents/plan/serializer/ActionJsonDeserializer.java index 1d83b87..0ae8b8a 100644 --- a/plan/src/main/java/org/apache/flink/agents/plan/serializer/ActionJsonDeserializer.java +++ b/plan/src/main/java/org/apache/flink/agents/plan/serializer/ActionJsonDeserializer.java @@ -18,10 +18,10 @@ package org.apache.flink.agents.plan.serializer; -import org.apache.flink.agents.plan.Action; import org.apache.flink.agents.plan.Function; import org.apache.flink.agents.plan.JavaFunction; import org.apache.flink.agents.plan.PythonFunction; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonNode; diff --git a/plan/src/main/java/org/apache/flink/agents/plan/serializer/ActionJsonSerializer.java b/plan/src/main/java/org/apache/flink/agents/plan/serializer/ActionJsonSerializer.java index 4aea2be..defdf69 100644 --- a/plan/src/main/java/org/apache/flink/agents/plan/serializer/ActionJsonSerializer.java +++ b/plan/src/main/java/org/apache/flink/agents/plan/serializer/ActionJsonSerializer.java @@ -18,9 +18,9 @@ package org.apache.flink.agents.plan.serializer; -import org.apache.flink.agents.plan.Action; import org.apache.flink.agents.plan.JavaFunction; import org.apache.flink.agents.plan.PythonFunction; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonGenerator; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.SerializerProvider; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ser.std.StdSerializer; diff --git a/plan/src/main/java/org/apache/flink/agents/plan/serializer/AgentPlanJsonDeserializer.java b/plan/src/main/java/org/apache/flink/agents/plan/serializer/AgentPlanJsonDeserializer.java index 5b8e8f8..a45ed3e 100644 --- a/plan/src/main/java/org/apache/flink/agents/plan/serializer/AgentPlanJsonDeserializer.java +++ b/plan/src/main/java/org/apache/flink/agents/plan/serializer/AgentPlanJsonDeserializer.java @@ -19,9 +19,9 @@ package org.apache.flink.agents.plan.serializer; import org.apache.flink.agents.api.resource.ResourceType; -import org.apache.flink.agents.plan.Action; import org.apache.flink.agents.plan.AgentConfiguration; import org.apache.flink.agents.plan.AgentPlan; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.agents.plan.resourceprovider.ResourceProvider; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JacksonException; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser; diff --git a/plan/src/main/java/org/apache/flink/agents/plan/serializer/AgentPlanJsonSerializer.java b/plan/src/main/java/org/apache/flink/agents/plan/serializer/AgentPlanJsonSerializer.java index ca61c79..6fe5584 100644 --- a/plan/src/main/java/org/apache/flink/agents/plan/serializer/AgentPlanJsonSerializer.java +++ b/plan/src/main/java/org/apache/flink/agents/plan/serializer/AgentPlanJsonSerializer.java @@ -19,8 +19,8 @@ package org.apache.flink.agents.plan.serializer; import org.apache.flink.agents.api.resource.ResourceType; -import org.apache.flink.agents.plan.Action; import org.apache.flink.agents.plan.AgentPlan; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.agents.plan.resourceprovider.ResourceProvider; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonGenerator; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.SerializerProvider; diff --git a/plan/src/test/java/org/apache/flink/agents/plan/AgentPlanTest.java b/plan/src/test/java/org/apache/flink/agents/plan/AgentPlanTest.java index ae7f36a..2a5d024 100644 --- a/plan/src/test/java/org/apache/flink/agents/plan/AgentPlanTest.java +++ b/plan/src/test/java/org/apache/flink/agents/plan/AgentPlanTest.java @@ -28,6 +28,7 @@ import org.apache.flink.agents.api.context.RunnerContext; import org.apache.flink.agents.api.resource.Resource; import org.apache.flink.agents.api.resource.ResourceType; import org.apache.flink.agents.api.resource.SerializableResource; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.agents.plan.resourceprovider.JavaSerializableResourceProvider; import org.apache.flink.agents.plan.resourceprovider.ResourceProvider; import org.junit.jupiter.api.Assertions; diff --git a/plan/src/test/java/org/apache/flink/agents/plan/TestAction.java b/plan/src/test/java/org/apache/flink/agents/plan/TestAction.java index 7b93b85..e4dac05 100644 --- a/plan/src/test/java/org/apache/flink/agents/plan/TestAction.java +++ b/plan/src/test/java/org/apache/flink/agents/plan/TestAction.java @@ -19,6 +19,7 @@ package org.apache.flink.agents.plan; import org.apache.flink.agents.api.InputEvent; import org.apache.flink.agents.api.context.RunnerContext; +import org.apache.flink.agents.plan.actions.Action; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Test; diff --git a/plan/src/test/java/org/apache/flink/agents/plan/compatibility/CreateJavaAgentPlanFromJson.java b/plan/src/test/java/org/apache/flink/agents/plan/compatibility/CreateJavaAgentPlanFromJson.java index 2a9e365..05e1604 100644 --- a/plan/src/test/java/org/apache/flink/agents/plan/compatibility/CreateJavaAgentPlanFromJson.java +++ b/plan/src/test/java/org/apache/flink/agents/plan/compatibility/CreateJavaAgentPlanFromJson.java @@ -19,9 +19,9 @@ package org.apache.flink.agents.plan.compatibility; import org.apache.flink.agents.api.resource.ResourceType; -import org.apache.flink.agents.plan.Action; import org.apache.flink.agents.plan.AgentPlan; import org.apache.flink.agents.plan.PythonFunction; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.agents.plan.resourceprovider.PythonResourceProvider; import org.apache.flink.agents.plan.resourceprovider.PythonSerializableResourceProvider; import org.apache.flink.agents.plan.resourceprovider.ResourceProvider; diff --git a/plan/src/test/java/org/apache/flink/agents/plan/serializer/ActionJsonDeserializerTest.java b/plan/src/test/java/org/apache/flink/agents/plan/serializer/ActionJsonDeserializerTest.java index 92919a9..94f903b 100644 --- a/plan/src/test/java/org/apache/flink/agents/plan/serializer/ActionJsonDeserializerTest.java +++ b/plan/src/test/java/org/apache/flink/agents/plan/serializer/ActionJsonDeserializerTest.java @@ -20,9 +20,9 @@ package org.apache.flink.agents.plan.serializer; import org.apache.flink.agents.api.InputEvent; import org.apache.flink.agents.api.context.RunnerContext; -import org.apache.flink.agents.plan.Action; import org.apache.flink.agents.plan.JavaFunction; import org.apache.flink.agents.plan.PythonFunction; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper; import org.junit.jupiter.api.Test; diff --git a/plan/src/test/java/org/apache/flink/agents/plan/serializer/ActionJsonSerializerTest.java b/plan/src/test/java/org/apache/flink/agents/plan/serializer/ActionJsonSerializerTest.java index d01ba65..56fe2dd 100644 --- a/plan/src/test/java/org/apache/flink/agents/plan/serializer/ActionJsonSerializerTest.java +++ b/plan/src/test/java/org/apache/flink/agents/plan/serializer/ActionJsonSerializerTest.java @@ -21,9 +21,9 @@ package org.apache.flink.agents.plan.serializer; import org.apache.flink.agents.api.InputEvent; import org.apache.flink.agents.api.OutputEvent; import org.apache.flink.agents.api.context.RunnerContext; -import org.apache.flink.agents.plan.Action; import org.apache.flink.agents.plan.JavaFunction; import org.apache.flink.agents.plan.PythonFunction; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Test; diff --git a/plan/src/test/java/org/apache/flink/agents/plan/serializer/AgentPlanJsonDeserializerTest.java b/plan/src/test/java/org/apache/flink/agents/plan/serializer/AgentPlanJsonDeserializerTest.java index 2cd3018..492575f 100644 --- a/plan/src/test/java/org/apache/flink/agents/plan/serializer/AgentPlanJsonDeserializerTest.java +++ b/plan/src/test/java/org/apache/flink/agents/plan/serializer/AgentPlanJsonDeserializerTest.java @@ -21,9 +21,9 @@ package org.apache.flink.agents.plan.serializer; import org.apache.flink.agents.api.Event; import org.apache.flink.agents.api.InputEvent; import org.apache.flink.agents.api.context.RunnerContext; -import org.apache.flink.agents.plan.Action; import org.apache.flink.agents.plan.AgentPlan; import org.apache.flink.agents.plan.JavaFunction; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper; import org.junit.jupiter.api.Test; diff --git a/plan/src/test/java/org/apache/flink/agents/plan/serializer/AgentPlanJsonSerializerTest.java b/plan/src/test/java/org/apache/flink/agents/plan/serializer/AgentPlanJsonSerializerTest.java index ec18751..ced31d6 100644 --- a/plan/src/test/java/org/apache/flink/agents/plan/serializer/AgentPlanJsonSerializerTest.java +++ b/plan/src/test/java/org/apache/flink/agents/plan/serializer/AgentPlanJsonSerializerTest.java @@ -23,10 +23,10 @@ import org.apache.flink.agents.api.Event; import org.apache.flink.agents.api.InputEvent; import org.apache.flink.agents.api.OutputEvent; import org.apache.flink.agents.api.context.RunnerContext; -import org.apache.flink.agents.plan.Action; import org.apache.flink.agents.plan.AgentConfiguration; import org.apache.flink.agents.plan.AgentPlan; import org.apache.flink.agents.plan.JavaFunction; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper; import org.junit.jupiter.api.Test; diff --git a/runtime/src/main/java/org/apache/flink/agents/runtime/actionstate/ActionStateStore.java b/runtime/src/main/java/org/apache/flink/agents/runtime/actionstate/ActionStateStore.java index e19450d..82850dc 100644 --- a/runtime/src/main/java/org/apache/flink/agents/runtime/actionstate/ActionStateStore.java +++ b/runtime/src/main/java/org/apache/flink/agents/runtime/actionstate/ActionStateStore.java @@ -18,7 +18,7 @@ package org.apache.flink.agents.runtime.actionstate; import org.apache.flink.agents.api.Event; -import org.apache.flink.agents.plan.Action; +import org.apache.flink.agents.plan.actions.Action; import java.io.IOException; import java.util.List; diff --git a/runtime/src/main/java/org/apache/flink/agents/runtime/actionstate/ActionStateUtil.java b/runtime/src/main/java/org/apache/flink/agents/runtime/actionstate/ActionStateUtil.java index daed7c3..bd9429a 100644 --- a/runtime/src/main/java/org/apache/flink/agents/runtime/actionstate/ActionStateUtil.java +++ b/runtime/src/main/java/org/apache/flink/agents/runtime/actionstate/ActionStateUtil.java @@ -19,7 +19,7 @@ package org.apache.flink.agents.runtime.actionstate; import org.apache.flink.agents.api.Event; import org.apache.flink.agents.api.InputEvent; -import org.apache.flink.agents.plan.Action; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.agents.runtime.python.event.PythonEvent; import org.apache.flink.shaded.guava31.com.google.common.base.Preconditions; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper; diff --git a/runtime/src/main/java/org/apache/flink/agents/runtime/actionstate/KafkaActionStateStore.java b/runtime/src/main/java/org/apache/flink/agents/runtime/actionstate/KafkaActionStateStore.java index 6b6ced8..aab3d5d 100644 --- a/runtime/src/main/java/org/apache/flink/agents/runtime/actionstate/KafkaActionStateStore.java +++ b/runtime/src/main/java/org/apache/flink/agents/runtime/actionstate/KafkaActionStateStore.java @@ -18,7 +18,7 @@ package org.apache.flink.agents.runtime.actionstate; import org.apache.flink.agents.api.Event; -import org.apache.flink.agents.plan.Action; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.annotation.VisibleForTesting; import java.io.IOException; 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 46ece97..81a0439 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 @@ -27,10 +27,10 @@ import org.apache.flink.agents.api.logger.EventLogger; import org.apache.flink.agents.api.logger.EventLoggerConfig; import org.apache.flink.agents.api.logger.EventLoggerFactory; import org.apache.flink.agents.api.logger.EventLoggerOpenParams; -import org.apache.flink.agents.plan.Action; import org.apache.flink.agents.plan.AgentPlan; import org.apache.flink.agents.plan.JavaFunction; import org.apache.flink.agents.plan.PythonFunction; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.agents.runtime.actionstate.ActionState; import org.apache.flink.agents.runtime.actionstate.ActionStateStore; import org.apache.flink.agents.runtime.actionstate.KafkaActionStateStore; diff --git a/runtime/src/main/java/org/apache/flink/agents/runtime/operator/ActionTask.java b/runtime/src/main/java/org/apache/flink/agents/runtime/operator/ActionTask.java index 60ecab0..5dff8a5 100644 --- a/runtime/src/main/java/org/apache/flink/agents/runtime/operator/ActionTask.java +++ b/runtime/src/main/java/org/apache/flink/agents/runtime/operator/ActionTask.java @@ -18,7 +18,7 @@ package org.apache.flink.agents.runtime.operator; import org.apache.flink.agents.api.Event; -import org.apache.flink.agents.plan.Action; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.agents.runtime.context.RunnerContextImpl; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/runtime/src/main/java/org/apache/flink/agents/runtime/operator/JavaActionTask.java b/runtime/src/main/java/org/apache/flink/agents/runtime/operator/JavaActionTask.java index 71d04b8..894df22 100644 --- a/runtime/src/main/java/org/apache/flink/agents/runtime/operator/JavaActionTask.java +++ b/runtime/src/main/java/org/apache/flink/agents/runtime/operator/JavaActionTask.java @@ -18,8 +18,8 @@ package org.apache.flink.agents.runtime.operator; import org.apache.flink.agents.api.Event; -import org.apache.flink.agents.plan.Action; import org.apache.flink.agents.plan.JavaFunction; +import org.apache.flink.agents.plan.actions.Action; import static org.apache.flink.util.Preconditions.checkState; diff --git a/runtime/src/main/java/org/apache/flink/agents/runtime/python/operator/PythonActionTask.java b/runtime/src/main/java/org/apache/flink/agents/runtime/python/operator/PythonActionTask.java index 53fb93b..128abbf 100644 --- a/runtime/src/main/java/org/apache/flink/agents/runtime/python/operator/PythonActionTask.java +++ b/runtime/src/main/java/org/apache/flink/agents/runtime/python/operator/PythonActionTask.java @@ -18,8 +18,8 @@ package org.apache.flink.agents.runtime.python.operator; import org.apache.flink.agents.api.Event; -import org.apache.flink.agents.plan.Action; import org.apache.flink.agents.plan.PythonFunction; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.agents.runtime.operator.ActionTask; import org.apache.flink.agents.runtime.python.event.PythonEvent; import org.apache.flink.agents.runtime.python.utils.PythonActionExecutor; diff --git a/runtime/src/main/java/org/apache/flink/agents/runtime/python/operator/PythonGeneratorActionTask.java b/runtime/src/main/java/org/apache/flink/agents/runtime/python/operator/PythonGeneratorActionTask.java index bc13f20..f3f7792 100644 --- a/runtime/src/main/java/org/apache/flink/agents/runtime/python/operator/PythonGeneratorActionTask.java +++ b/runtime/src/main/java/org/apache/flink/agents/runtime/python/operator/PythonGeneratorActionTask.java @@ -18,7 +18,7 @@ package org.apache.flink.agents.runtime.python.operator; import org.apache.flink.agents.api.Event; -import org.apache.flink.agents.plan.Action; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.agents.runtime.operator.ActionTask; import org.apache.flink.agents.runtime.python.utils.PythonActionExecutor; diff --git a/runtime/src/test/java/org/apache/flink/agents/runtime/actionstate/ActionStateUtilTest.java b/runtime/src/test/java/org/apache/flink/agents/runtime/actionstate/ActionStateUtilTest.java index b66e7e4..fbe500b 100644 --- a/runtime/src/test/java/org/apache/flink/agents/runtime/actionstate/ActionStateUtilTest.java +++ b/runtime/src/test/java/org/apache/flink/agents/runtime/actionstate/ActionStateUtilTest.java @@ -20,8 +20,8 @@ package org.apache.flink.agents.runtime.actionstate; import org.apache.flink.agents.api.Event; import org.apache.flink.agents.api.InputEvent; import org.apache.flink.agents.api.context.RunnerContext; -import org.apache.flink.agents.plan.Action; import org.apache.flink.agents.plan.JavaFunction; +import org.apache.flink.agents.plan.actions.Action; import org.junit.jupiter.api.Test; import java.util.List; diff --git a/runtime/src/test/java/org/apache/flink/agents/runtime/actionstate/InMemoryActionStateStore.java b/runtime/src/test/java/org/apache/flink/agents/runtime/actionstate/InMemoryActionStateStore.java index 0a5dc9c..8bf699e 100644 --- a/runtime/src/test/java/org/apache/flink/agents/runtime/actionstate/InMemoryActionStateStore.java +++ b/runtime/src/test/java/org/apache/flink/agents/runtime/actionstate/InMemoryActionStateStore.java @@ -18,7 +18,7 @@ package org.apache.flink.agents.runtime.actionstate; import org.apache.flink.agents.api.Event; -import org.apache.flink.agents.plan.Action; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.annotation.VisibleForTesting; import java.io.IOException; diff --git a/runtime/src/test/java/org/apache/flink/agents/runtime/operator/ActionExecutionOperatorTest.java b/runtime/src/test/java/org/apache/flink/agents/runtime/operator/ActionExecutionOperatorTest.java index ca39a17..3c4d125 100644 --- a/runtime/src/test/java/org/apache/flink/agents/runtime/operator/ActionExecutionOperatorTest.java +++ b/runtime/src/test/java/org/apache/flink/agents/runtime/operator/ActionExecutionOperatorTest.java @@ -22,9 +22,9 @@ import org.apache.flink.agents.api.InputEvent; import org.apache.flink.agents.api.OutputEvent; import org.apache.flink.agents.api.context.MemoryObject; import org.apache.flink.agents.api.context.RunnerContext; -import org.apache.flink.agents.plan.Action; import org.apache.flink.agents.plan.AgentPlan; import org.apache.flink.agents.plan.JavaFunction; +import org.apache.flink.agents.plan.actions.Action; import org.apache.flink.agents.runtime.actionstate.ActionState; import org.apache.flink.agents.runtime.actionstate.InMemoryActionStateStore; import org.apache.flink.api.common.typeinfo.TypeInformation;
