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 5776bf46 [bugfix][examples] Point quickstart FileSource at
product_review.txt instead of the resources dir (#782)
5776bf46 is described below
commit 5776bf46d523ea89b67929a141ea159d2f2c38fd
Author: bosiew.tian <[email protected]>
AuthorDate: Mon Jun 8 10:54:18 2026 +0800
[bugfix][examples] Point quickstart FileSource at product_review.txt
instead of the resources dir (#782)
---
docs/content/docs/get-started/quickstart/react_agent.md | 4 +++-
docs/content/docs/get-started/quickstart/workflow_agent.md | 5 ++++-
docs/content/docs/get-started/quickstart/yaml_agent.md | 5 ++++-
python/flink_agents/examples/quickstart/react_agent_example.py | 4 +++-
.../examples/quickstart/workflow_single_agent_example.py | 5 ++++-
.../flink_agents/examples/quickstart/yaml_workflow_agent_example.py | 5 ++++-
6 files changed, 22 insertions(+), 6 deletions(-)
diff --git a/docs/content/docs/get-started/quickstart/react_agent.md
b/docs/content/docs/get-started/quickstart/react_agent.md
index 5a1cafca..a4de2704 100644
--- a/docs/content/docs/get-started/quickstart/react_agent.md
+++ b/docs/content/docs/get-started/quickstart/react_agent.md
@@ -132,9 +132,11 @@ Produce a source DataStream by reading a product review
text file, and use the R
# Read product reviews from a text file as a streaming source.
# Each line in the file should be a JSON string representing a ProductReview.
product_review_stream = env.from_source(
+ # Target the single file, not the resources/ dir: Flink's enumerator
+ # recurses, so files like skills/SKILL.md would be parsed as reviews.
source=FileSource.for_record_stream_format(
StreamFormat.text_line_format(),
- f"file:///{current_dir}/resources/",
+ f"file:///{current_dir}/resources/product_review.txt",
)
.monitor_continuously(Duration.of_minutes(1))
.build(),
diff --git a/docs/content/docs/get-started/quickstart/workflow_agent.md
b/docs/content/docs/get-started/quickstart/workflow_agent.md
index b1d2e9a5..549bc041 100644
--- a/docs/content/docs/get-started/quickstart/workflow_agent.md
+++ b/docs/content/docs/get-started/quickstart/workflow_agent.md
@@ -284,8 +284,11 @@ Create the input DataStream by reading the product reviews
from a text file as a
# Read product reviews from a text file as a streaming source.
# Each line in the file should be a JSON string representing a ProductReview.
product_review_stream = env.from_source(
+ # Target the single file, not the resources/ dir: Flink's enumerator
+ # recurses, so files like skills/SKILL.md would be parsed as reviews.
source=FileSource.for_record_stream_format(
- StreamFormat.text_line_format(), f"file:///{current_dir}/resources"
+ StreamFormat.text_line_format(),
+ f"file:///{current_dir}/resources/product_review.txt",
)
.monitor_continuously(Duration.of_minutes(1))
.build(),
diff --git a/docs/content/docs/get-started/quickstart/yaml_agent.md
b/docs/content/docs/get-started/quickstart/yaml_agent.md
index 233d7128..a297e0ef 100644
--- a/docs/content/docs/get-started/quickstart/yaml_agent.md
+++ b/docs/content/docs/get-started/quickstart/yaml_agent.md
@@ -212,8 +212,11 @@ agents_env.load_yaml(current_dir /
"yaml_review_analysis_agent.yaml")
# Read product reviews from a text file as a streaming source.
product_review_stream = env.from_source(
+ # Target the single file, not the resources/ dir: Flink's enumerator
+ # recurses, so files like skills/SKILL.md would be parsed as reviews.
source=FileSource.for_record_stream_format(
- StreamFormat.text_line_format(), f"file:///{current_dir}/resources"
+ StreamFormat.text_line_format(),
+ f"file:///{current_dir}/resources/product_review.txt",
)
.monitor_continuously(Duration.of_minutes(1))
.build(),
diff --git a/python/flink_agents/examples/quickstart/react_agent_example.py
b/python/flink_agents/examples/quickstart/react_agent_example.py
index 71d3ea76..4602aeb5 100644
--- a/python/flink_agents/examples/quickstart/react_agent_example.py
+++ b/python/flink_agents/examples/quickstart/react_agent_example.py
@@ -74,9 +74,11 @@ def main() -> None:
# Read product reviews from a text file as a streaming source.
# Each line in the file should be a JSON string representing a
ProductReview.
product_review_stream = env.from_source(
+ # Target the single file, not the resources/ dir: Flink's enumerator
+ # recurses, so files like skills/SKILL.md would be parsed as reviews.
source=FileSource.for_record_stream_format(
StreamFormat.text_line_format(),
- f"file:///{current_dir}/resources/",
+ f"file:///{current_dir}/resources/product_review.txt",
)
.monitor_continuously(Duration.of_minutes(1))
.build(),
diff --git
a/python/flink_agents/examples/quickstart/workflow_single_agent_example.py
b/python/flink_agents/examples/quickstart/workflow_single_agent_example.py
index ed81e5fe..c532698e 100644
--- a/python/flink_agents/examples/quickstart/workflow_single_agent_example.py
+++ b/python/flink_agents/examples/quickstart/workflow_single_agent_example.py
@@ -61,8 +61,11 @@ def main() -> None:
# Read product reviews from a text file as a streaming source.
# Each line in the file should be a JSON string representing a
ProductReview.
product_review_stream = env.from_source(
+ # Target the single file, not the resources/ dir: Flink's enumerator
+ # recurses, so files like skills/SKILL.md would be parsed as reviews.
source=FileSource.for_record_stream_format(
- StreamFormat.text_line_format(), f"file:///{current_dir}/resources"
+ StreamFormat.text_line_format(),
+ f"file:///{current_dir}/resources/product_review.txt",
)
.monitor_continuously(Duration.of_minutes(1))
.build(),
diff --git
a/python/flink_agents/examples/quickstart/yaml_workflow_agent_example.py
b/python/flink_agents/examples/quickstart/yaml_workflow_agent_example.py
index 9291de66..17c39952 100644
--- a/python/flink_agents/examples/quickstart/yaml_workflow_agent_example.py
+++ b/python/flink_agents/examples/quickstart/yaml_workflow_agent_example.py
@@ -54,8 +54,11 @@ def main() -> None:
# Read product reviews from a text file as a streaming source.
# Each line in the file should be a JSON string representing a
ProductReview.
product_review_stream = env.from_source(
+ # Target the single file, not the resources/ dir: Flink's enumerator
+ # recurses, so files like skills/SKILL.md would be parsed as reviews.
source=FileSource.for_record_stream_format(
- StreamFormat.text_line_format(), f"file:///{current_dir}/resources"
+ StreamFormat.text_line_format(),
+ f"file:///{current_dir}/resources/product_review.txt",
)
.monitor_continuously(Duration.of_minutes(1))
.build(),
