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 0ae6e7d4 [e2e][java] Validate ReActAgent output without schema (#927)
0ae6e7d4 is described below
commit 0ae6e7d4c883bbdbc44b3b07eb7afea439ad2c8f
Author: Wenjin Xie <[email protected]>
AuthorDate: Sat Jul 25 13:00:45 2026 +0800
[e2e][java] Validate ReActAgent output without schema (#927)
---
.../org/apache/flink/agents/integration/test/ReActAgentTest.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git
a/e2e-test/flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/ReActAgentTest.java
b/e2e-test/flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/ReActAgentTest.java
index 7bff4550..38eb800b 100644
---
a/e2e-test/flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/ReActAgentTest.java
+++
b/e2e-test/flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/ReActAgentTest.java
@@ -215,9 +215,14 @@ public class ReActAgentTest {
.apply(agent)
.toDataStream();
- out.print();
+ CloseableIterator<Object> results = out.collectAsync();
env.execute();
+
+ Assertions.assertTrue(results.hasNext(), "The agent should emit a
result.");
+ Assertions.assertTrue(
+ results.next() instanceof String,
+ "The result should be a String when no output schema is
provided.");
}
// create ReAct agent; pass false to skip the output schema.
