From 0ae6e7d4c883bbdbc44b3b07eb7afea439ad2c8f Mon Sep 17 00:00:00 2001
From: Wenjin Xie <166717626+wenjin272@users.noreply.github.com>
Date: Sat, 25 Jul 2026 13:00:45 +0800
Subject: [PATCH] [e2e][java] Validate ReActAgent output without schema (#927)

---
 .../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 7bff4550b..38eb800bc 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 void testReActAgentNoOutputSchema() throws Exception {
                         .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.