This is an automated email from the ASF dual-hosted git repository.
wenjin272 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-agents.git
The following commit(s) were added to refs/heads/main by this push:
new e98aab61f [hotfix][ci] Reduce test logs and update Java IT and ReAct
tests (#1323)
e98aab61f is described below
commit e98aab61f6a4aef0a8e28598be6d925a5fa2b19e
Author: Wenjin Xie <[email protected]>
AuthorDate: Sat Oct 24 17:34:52 2026 +0800
[hotfix][ci] Reduce test logs and update Java IT and ReAct tests (#1323)
Generated-by: Codex CLI 0.153.4 (GPT-6)
Co-authored-by: Codex <[email protected]>
---
.github/workflows/ci.yml | 2 +-
.../e2e_tests_integration/react_agent_test.py | 5 +++-
.../flink/agents/runtime/CompileUtilsTest.java | 4 +++
.../apache/flink/agents/runtime/RescalingTest.java | 32 ++++++++++++++++++++--
4 files changed, 38 insertions(+), 5 deletions(-)
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
index e260bacbd..dfc7e04ea 100644
--- a/.github/workflows/ci.yml
+++ b/.github/workflows/ci.yml
@@ -268,7 +268,7 @@ jobs:
java-version: "21"
flink-version: "2.2"
- os: 'ubuntu-latest'
- java-version: "17"
+ java-version: "21"
flink-version: "2.3"
steps:
- uses: actions/checkout@v7
diff --git
a/python/flink_agents/e2e_tests/e2e_tests_integration/react_agent_test.py
b/python/flink_agents/e2e_tests/e2e_tests_integration/react_agent_test.py
index a7a5d7eb7..23b39384d 100644
--- a/python/flink_agents/e2e_tests/e2e_tests_integration/react_agent_test.py
+++ b/python/flink_agents/e2e_tests/e2e_tests_integration/react_agent_test.py
@@ -57,7 +57,7 @@ current_dir = Path(__file__).parent
os.environ["PYTHONPATH"] = sysconfig.get_paths()["purelib"]
-OLLAMA_MODEL = os.environ.get("REACT_OLLAMA_MODEL", "qwen3:1.7b")
+OLLAMA_MODEL = os.environ.get("REACT_OLLAMA_MODEL", "qwen3.5:2b")
class MyKeySelector(KeySelector):
@@ -140,6 +140,7 @@ def test_react_agent_on_remote_runner(
clazz=ResourceName.ChatModel.OLLAMA_SETUP,
connection="ollama",
model=OLLAMA_MODEL,
+ think=False,
tools=["add", "multiply"],
),
prompt=prompt,
@@ -251,6 +252,7 @@ def test_react_agent_no_output_schema_on_remote_runner(
clazz=ResourceName.ChatModel.OLLAMA_SETUP,
connection="ollama",
model=OLLAMA_MODEL,
+ think=False,
tools=["add", "multiply"],
),
prompt=prompt,
@@ -330,6 +332,7 @@ def
test_react_agent_native_structured_output_on_remote_runner(
clazz=ResourceName.ChatModel.OLLAMA_SETUP,
connection="recording_ollama",
model=OLLAMA_MODEL,
+ think=False,
tools=["add", "multiply"],
),
prompt=prompt,
diff --git
a/runtime/src/test/java/org/apache/flink/agents/runtime/CompileUtilsTest.java
b/runtime/src/test/java/org/apache/flink/agents/runtime/CompileUtilsTest.java
index ba25351cf..3787bda49 100644
---
a/runtime/src/test/java/org/apache/flink/agents/runtime/CompileUtilsTest.java
+++
b/runtime/src/test/java/org/apache/flink/agents/runtime/CompileUtilsTest.java
@@ -18,6 +18,7 @@
package org.apache.flink.agents.runtime;
import com.fasterxml.jackson.core.JsonProcessingException;
+import org.apache.flink.agents.api.configuration.AgentConfigOptions;
import org.apache.flink.agents.plan.AgentPlan;
import org.apache.flink.agents.runtime.operator.ActionExecutionOperatorTest;
import org.apache.flink.api.common.RuntimeExecutionMode;
@@ -67,6 +68,9 @@ public class CompileUtilsTest {
@BeforeAll
static void setup() {
+ TEST_AGENT_PLAN
+ .getConfig()
+ .set(AgentConfigOptions.TRACE_LOG_TARGETS,
Collections.emptyList());
testSequence = getTestSequence();
testSequence.sort(Long::compareTo);
}
diff --git
a/runtime/src/test/java/org/apache/flink/agents/runtime/RescalingTest.java
b/runtime/src/test/java/org/apache/flink/agents/runtime/RescalingTest.java
index bdd5efe1b..4f24f7fe5 100644
--- a/runtime/src/test/java/org/apache/flink/agents/runtime/RescalingTest.java
+++ b/runtime/src/test/java/org/apache/flink/agents/runtime/RescalingTest.java
@@ -24,6 +24,7 @@ import org.apache.flink.agents.api.InputEvent;
import org.apache.flink.agents.api.OutputEvent;
import org.apache.flink.agents.api.agents.Agent;
import org.apache.flink.agents.api.annotation.Action;
+import org.apache.flink.agents.api.configuration.AgentConfigOptions;
import org.apache.flink.agents.api.context.RunnerContext;
import org.apache.flink.agents.plan.AgentPlan;
import org.apache.flink.api.common.JobID;
@@ -59,10 +60,14 @@ import org.apache.flink.testutils.TestingUtils;
import org.apache.flink.testutils.executor.TestExecutorResource;
import org.apache.flink.util.Collector;
import org.apache.flink.util.TestLogger;
+import org.apache.logging.log4j.Level;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.core.config.Configurator;
import org.junit.AfterClass;
import org.junit.Before;
import org.junit.ClassRule;
import org.junit.Test;
+import org.junit.rules.ExternalResource;
import org.junit.rules.TemporaryFolder;
import org.junit.runner.RunWith;
import org.junit.runners.Parameterized;
@@ -92,6 +97,26 @@ import static org.junit.Assert.assertTrue;
@RunWith(Parameterized.class)
public class RescalingTest extends TestLogger {
+ // Suppress MiniCluster INFO logs for this class, including cluster
shutdown.
+ @ClassRule
+ public static final ExternalResource LOG_LEVEL =
+ new ExternalResource() {
+ private Level originalLevel;
+
+ @Override
+ protected void before() {
+ originalLevel = LogManager.getRootLogger().getLevel();
+ if (originalLevel.isLessSpecificThan(Level.WARN)) {
+ Configurator.setRootLevel(Level.WARN);
+ }
+ }
+
+ @Override
+ protected void after() {
+ Configurator.setRootLevel(originalLevel);
+ }
+ };
+
@ClassRule
public static final TestExecutorResource<ScheduledExecutorService>
EXECUTOR_RESOURCE =
TestingUtils.defaultExecutorResource();
@@ -318,10 +343,11 @@ public class RescalingTest extends TestLogger {
});
// insert agent topology
+ AgentPlan agentPlan = new AgentPlan(new TestAgent());
+ // This bulk state-recovery test does not verify per-event trace logs.
+ agentPlan.getConfig().set(AgentConfigOptions.TRACE_LOG_TARGETS,
Collections.emptyList());
input =
- CompileUtils.connectToAgent(
- (KeyedStream<Integer, Integer>) input,
- new AgentPlan(new TestAgent()))
+ CompileUtils.connectToAgent((KeyedStream<Integer, Integer>)
input, agentPlan)
.map(
new MapFunction<Object, Integer>() {
@Override
