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 5bf126da0a59232c47408c737e928917f4ce4fd0 Author: WenjinXie <[email protected]> AuthorDate: Fri Sep 26 14:11:27 2025 +0800 [hotfix] Move test purpose example to e2e test module in java. --- e2e-test/integration-test/pom.xml | 69 ++++++++++++++++++++++ .../agents/integration/test}/AgentWithOllama.java | 2 +- .../integration/test}/AgentWithOllamaExample.java | 2 +- .../integration/test}/AgentWithResource.java | 2 +- .../test}/AgentWithResourceExample.java | 2 +- .../agents/integration/test}/DataStreamAgent.java | 4 +- .../test}/DataStreamIntegrationExample.java | 2 +- .../integration/test}/MemoryObjectAgent.java | 2 +- .../integration/test}/MemoryObjectExample.java | 2 +- .../integration/test}/ReActAgentExample.java | 2 +- .../agents/integration/test}/SimpleAgent.java | 2 +- .../flink/agents/integration/test}/TableAgent.java | 2 +- .../integration/test}/TableIntegrationExample.java | 2 +- e2e-test/pom.xml | 1 + 14 files changed, 83 insertions(+), 13 deletions(-) diff --git a/e2e-test/integration-test/pom.xml b/e2e-test/integration-test/pom.xml new file mode 100644 index 0000000..598da38 --- /dev/null +++ b/e2e-test/integration-test/pom.xml @@ -0,0 +1,69 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- +Licensed to the Apache Software Foundation (ASF) under one +or more contributor license agreements. See the NOTICE file +distributed with this work for additional information +regarding copyright ownership. The ASF licenses this file +to you under the Apache License, Version 2.0 (the +"License"); you may not use this file except in compliance +with the License. You may obtain a copy of the License at + http://www.apache.org/licenses/LICENSE-2.0 +Unless required by applicable law or agreed to in writing, +software distributed under the License is distributed on an +"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +KIND, either express or implied. See the License for the +specific language governing permissions and limitations +under the License. +--> +<project xmlns="http://maven.apache.org/POM/4.0.0"; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> + <modelVersion>4.0.0</modelVersion> + <parent> + <groupId>org.apache.flink</groupId> + <artifactId>flink-agents-e2e-tests</artifactId> + <version>0.1-SNAPSHOT</version> + </parent> + + <artifactId>flink-agents-integration-tests</artifactId> + <name>Flink Agents : E2E Tests: Integration</name> + + <dependencies> + <dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-agents-api</artifactId> + <version>${project.version}</version> + </dependency> + <dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-agents-runtime</artifactId> + <version>${project.version}</version> + </dependency> + <dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-streaming-java</artifactId> + <version>${flink.version}</version> + </dependency> + <dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-table-api-java-bridge</artifactId> + <version>${flink.version}</version> + </dependency> + <dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-table-planner_2.12</artifactId> + <version>${flink.version}</version> + </dependency> + <dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-clients</artifactId> + <version>${flink.version}</version> + </dependency> + <dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-agents-integrations-chat-models-ollama</artifactId> + <version>${project.version}</version> + </dependency> + </dependencies> + +</project> \ No newline at end of file diff --git a/examples/src/main/java/org/apache/flink/agents/examples/AgentWithOllama.java b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithOllama.java similarity index 99% rename from examples/src/main/java/org/apache/flink/agents/examples/AgentWithOllama.java rename to e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithOllama.java index b371444..00c4144 100644 --- a/examples/src/main/java/org/apache/flink/agents/examples/AgentWithOllama.java +++ b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithOllama.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.agents.examples; +package org.apache.flink.agents.integration.test; import org.apache.flink.agents.api.Agent; import org.apache.flink.agents.api.InputEvent; diff --git a/examples/src/main/java/org/apache/flink/agents/examples/AgentWithOllamaExample.java b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithOllamaExample.java similarity index 98% rename from examples/src/main/java/org/apache/flink/agents/examples/AgentWithOllamaExample.java rename to e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithOllamaExample.java index 7a850c5..c58f6b4 100644 --- a/examples/src/main/java/org/apache/flink/agents/examples/AgentWithOllamaExample.java +++ b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithOllamaExample.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.agents.examples; +package org.apache.flink.agents.integration.test; import org.apache.flink.agents.api.AgentsExecutionEnvironment; import org.apache.flink.api.java.functions.KeySelector; diff --git a/examples/src/main/java/org/apache/flink/agents/examples/AgentWithResource.java b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithResource.java similarity index 99% rename from examples/src/main/java/org/apache/flink/agents/examples/AgentWithResource.java rename to e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithResource.java index 27ee17b..101df78 100644 --- a/examples/src/main/java/org/apache/flink/agents/examples/AgentWithResource.java +++ b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithResource.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.agents.examples; +package org.apache.flink.agents.integration.test; import org.apache.flink.agents.api.Agent; import org.apache.flink.agents.api.InputEvent; diff --git a/examples/src/main/java/org/apache/flink/agents/examples/AgentWithResourceExample.java b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithResourceExample.java similarity index 98% rename from examples/src/main/java/org/apache/flink/agents/examples/AgentWithResourceExample.java rename to e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithResourceExample.java index 8ca3c75..c1828aa 100644 --- a/examples/src/main/java/org/apache/flink/agents/examples/AgentWithResourceExample.java +++ b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithResourceExample.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.flink.agents.examples; +package org.apache.flink.agents.integration.test; import org.apache.flink.agents.api.AgentsExecutionEnvironment; import org.apache.flink.api.java.functions.KeySelector; diff --git a/examples/src/main/java/org/apache/flink/agents/examples/DataStreamAgent.java b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/DataStreamAgent.java similarity index 96% rename from examples/src/main/java/org/apache/flink/agents/examples/DataStreamAgent.java rename to e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/DataStreamAgent.java index ffc1050..860412b 100644 --- a/examples/src/main/java/org/apache/flink/agents/examples/DataStreamAgent.java +++ b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/DataStreamAgent.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.flink.agents.examples; +package org.apache.flink.agents.integration.test; import org.apache.flink.agents.api.Agent; import org.apache.flink.agents.api.Event; @@ -25,7 +25,7 @@ import org.apache.flink.agents.api.annotation.Action; import org.apache.flink.agents.api.context.MemoryObject; import org.apache.flink.agents.api.context.MemoryRef; import org.apache.flink.agents.api.context.RunnerContext; -import org.apache.flink.agents.examples.DataStreamIntegrationExample.ItemData; +import org.apache.flink.agents.integration.test.DataStreamIntegrationExample.ItemData; /** * A simple example agent used for explaining integrating agents with DataStream. diff --git a/examples/src/main/java/org/apache/flink/agents/examples/DataStreamIntegrationExample.java b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/DataStreamIntegrationExample.java similarity index 98% rename from examples/src/main/java/org/apache/flink/agents/examples/DataStreamIntegrationExample.java rename to e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/DataStreamIntegrationExample.java index b3a3860..f87ec85 100644 --- a/examples/src/main/java/org/apache/flink/agents/examples/DataStreamIntegrationExample.java +++ b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/DataStreamIntegrationExample.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.agents.examples; +package org.apache.flink.agents.integration.test; import org.apache.flink.agents.api.AgentsExecutionEnvironment; import org.apache.flink.api.java.functions.KeySelector; diff --git a/examples/src/main/java/org/apache/flink/agents/examples/MemoryObjectAgent.java b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/MemoryObjectAgent.java similarity index 98% rename from examples/src/main/java/org/apache/flink/agents/examples/MemoryObjectAgent.java rename to e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/MemoryObjectAgent.java index bd34f8f..a54316c 100644 --- a/examples/src/main/java/org/apache/flink/agents/examples/MemoryObjectAgent.java +++ b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/MemoryObjectAgent.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.flink.agents.examples; +package org.apache.flink.agents.integration.test; import org.apache.flink.agents.api.Agent; import org.apache.flink.agents.api.Event; diff --git a/examples/src/main/java/org/apache/flink/agents/examples/MemoryObjectExample.java b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/MemoryObjectExample.java similarity index 97% rename from examples/src/main/java/org/apache/flink/agents/examples/MemoryObjectExample.java rename to e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/MemoryObjectExample.java index 8cac567..a0e2304 100644 --- a/examples/src/main/java/org/apache/flink/agents/examples/MemoryObjectExample.java +++ b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/MemoryObjectExample.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.flink.agents.examples; +package org.apache.flink.agents.integration.test; import org.apache.flink.agents.api.AgentsExecutionEnvironment; import org.apache.flink.api.java.functions.KeySelector; diff --git a/examples/src/main/java/org/apache/flink/agents/examples/ReActAgentExample.java b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/ReActAgentExample.java similarity index 99% rename from examples/src/main/java/org/apache/flink/agents/examples/ReActAgentExample.java rename to e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/ReActAgentExample.java index 251a7c2..fbce8fd 100644 --- a/examples/src/main/java/org/apache/flink/agents/examples/ReActAgentExample.java +++ b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/ReActAgentExample.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.agents.examples; +package org.apache.flink.agents.integration.test; import org.apache.flink.agents.api.Agent; import org.apache.flink.agents.api.AgentsExecutionEnvironment; diff --git a/examples/src/main/java/org/apache/flink/agents/examples/SimpleAgent.java b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/SimpleAgent.java similarity index 98% rename from examples/src/main/java/org/apache/flink/agents/examples/SimpleAgent.java rename to e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/SimpleAgent.java index 121596e..991162e 100644 --- a/examples/src/main/java/org/apache/flink/agents/examples/SimpleAgent.java +++ b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/SimpleAgent.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.agents.examples; +package org.apache.flink.agents.integration.test; import org.apache.flink.agents.api.Agent; import org.apache.flink.agents.api.Event; diff --git a/examples/src/main/java/org/apache/flink/agents/examples/TableAgent.java b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/TableAgent.java similarity index 98% rename from examples/src/main/java/org/apache/flink/agents/examples/TableAgent.java rename to e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/TableAgent.java index 44a7980..8582b17 100644 --- a/examples/src/main/java/org/apache/flink/agents/examples/TableAgent.java +++ b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/TableAgent.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.flink.agents.examples; +package org.apache.flink.agents.integration.test; import org.apache.flink.agents.api.Agent; import org.apache.flink.agents.api.Event; diff --git a/examples/src/main/java/org/apache/flink/agents/examples/TableIntegrationExample.java b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/TableIntegrationExample.java similarity index 98% rename from examples/src/main/java/org/apache/flink/agents/examples/TableIntegrationExample.java rename to e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/TableIntegrationExample.java index abce29c..30c4d17 100644 --- a/examples/src/main/java/org/apache/flink/agents/examples/TableIntegrationExample.java +++ b/e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/TableIntegrationExample.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.agents.examples; +package org.apache.flink.agents.integration.test; import org.apache.flink.agents.api.AgentsExecutionEnvironment; import org.apache.flink.api.java.functions.KeySelector; diff --git a/e2e-test/pom.xml b/e2e-test/pom.xml index e2895cd..c85bc2e 100644 --- a/e2e-test/pom.xml +++ b/e2e-test/pom.xml @@ -30,5 +30,6 @@ under the License. <name>Flink Agents : E2E Tests: </name> <modules> <module>agent-plan-compatibility-test</module> + <module>integration-test</module> </modules> </project> \ No newline at end of file
