This is an automated email from the ASF dual-hosted git repository. xtsong pushed a commit to branch release-0.2 in repository https://gitbox.apache.org/repos/asf/flink-agents.git
commit 37fa200fd5952f04dc7c92c62257ae4348cac730 Author: WenjinXie <[email protected]> AuthorDate: Thu Jan 29 14:41:21 2026 +0800 [example] Limit async chat request to avoid overwhelming ollama server. --- .../java/org/apache/flink/agents/examples/ReActAgentExample.java | 5 ++++- .../apache/flink/agents/examples/WorkflowMultipleAgentExample.java | 4 ++++ .../org/apache/flink/agents/examples/WorkflowSingleAgentExample.java | 4 ++++ python/flink_agents/examples/quickstart/react_agent_example.py | 4 ++++ .../examples/quickstart/workflow_multiple_agent_example.py | 4 ++++ .../examples/quickstart/workflow_single_agent_example.py | 4 ++++ 6 files changed, 24 insertions(+), 1 deletion(-) diff --git a/examples/src/main/java/org/apache/flink/agents/examples/ReActAgentExample.java b/examples/src/main/java/org/apache/flink/agents/examples/ReActAgentExample.java index 624f3b83..12100ad7 100644 --- a/examples/src/main/java/org/apache/flink/agents/examples/ReActAgentExample.java +++ b/examples/src/main/java/org/apache/flink/agents/examples/ReActAgentExample.java @@ -19,6 +19,7 @@ package org.apache.flink.agents.examples; import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.flink.agents.api.AgentsExecutionEnvironment; +import org.apache.flink.agents.api.agents.AgentExecutionOptions; import org.apache.flink.agents.api.agents.ReActAgent; import org.apache.flink.agents.api.annotation.Prompt; import org.apache.flink.agents.api.annotation.Tool; @@ -83,6 +84,9 @@ public class ReActAgentExample { AgentsExecutionEnvironment agentsEnv = AgentsExecutionEnvironment.getExecutionEnvironment(env); + // limit async request to avoid overwhelming ollama server + agentsEnv.getConfig().set(AgentExecutionOptions.NUM_ASYNC_THREADS, 2); + // Add Ollama chat model connection and record shipping question tool to be used // by the Agent. agentsEnv @@ -147,7 +151,6 @@ public class ReActAgentExample { ResourceDescriptor.Builder.newBuilder(ResourceName.ChatModel.OLLAMA_SETUP) .addInitialArgument("connection", "ollamaChatModelConnection") .addInitialArgument("model", "qwen3:8b") - .addInitialArgument("think", false) .addInitialArgument( "tools", Collections.singletonList("notifyShippingManager")) .build(), diff --git a/examples/src/main/java/org/apache/flink/agents/examples/WorkflowMultipleAgentExample.java b/examples/src/main/java/org/apache/flink/agents/examples/WorkflowMultipleAgentExample.java index fe91c581..874fa9e5 100644 --- a/examples/src/main/java/org/apache/flink/agents/examples/WorkflowMultipleAgentExample.java +++ b/examples/src/main/java/org/apache/flink/agents/examples/WorkflowMultipleAgentExample.java @@ -21,6 +21,7 @@ package org.apache.flink.agents.examples; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.flink.agents.api.AgentsExecutionEnvironment; +import org.apache.flink.agents.api.agents.AgentExecutionOptions; import org.apache.flink.agents.api.resource.ResourceType; import org.apache.flink.agents.examples.agents.CustomTypesAndResources; import org.apache.flink.agents.examples.agents.ProductSuggestionAgent; @@ -129,6 +130,9 @@ public class WorkflowMultipleAgentExample { AgentsExecutionEnvironment agentsEnv = AgentsExecutionEnvironment.getExecutionEnvironment(env); + // limit async request to avoid overwhelming ollama server + agentsEnv.getConfig().set(AgentExecutionOptions.NUM_ASYNC_THREADS, 2); + // Add Ollama chat model connection to be used by the ReviewAnalysisAgent // and ProductSuggestionAgent. agentsEnv.addResource( diff --git a/examples/src/main/java/org/apache/flink/agents/examples/WorkflowSingleAgentExample.java b/examples/src/main/java/org/apache/flink/agents/examples/WorkflowSingleAgentExample.java index f6854217..b2d49582 100644 --- a/examples/src/main/java/org/apache/flink/agents/examples/WorkflowSingleAgentExample.java +++ b/examples/src/main/java/org/apache/flink/agents/examples/WorkflowSingleAgentExample.java @@ -18,6 +18,7 @@ package org.apache.flink.agents.examples; import org.apache.flink.agents.api.AgentsExecutionEnvironment; +import org.apache.flink.agents.api.agents.AgentExecutionOptions; import org.apache.flink.agents.api.resource.ResourceType; import org.apache.flink.agents.examples.agents.CustomTypesAndResources; import org.apache.flink.agents.examples.agents.ReviewAnalysisAgent; @@ -55,6 +56,9 @@ public class WorkflowSingleAgentExample { AgentsExecutionEnvironment agentsEnv = AgentsExecutionEnvironment.getExecutionEnvironment(env); + // limit async request to avoid overwhelming ollama server + agentsEnv.getConfig().set(AgentExecutionOptions.NUM_ASYNC_THREADS, 2); + // Add Ollama chat model connection to be used by the ReviewAnalysisAgent. agentsEnv.addResource( "ollamaChatModelConnection", diff --git a/python/flink_agents/examples/quickstart/react_agent_example.py b/python/flink_agents/examples/quickstart/react_agent_example.py index ca309975..34d15971 100644 --- a/python/flink_agents/examples/quickstart/react_agent_example.py +++ b/python/flink_agents/examples/quickstart/react_agent_example.py @@ -22,6 +22,7 @@ from pyflink.datastream import StreamExecutionEnvironment from pyflink.datastream.connectors.file_system import FileSource, StreamFormat from flink_agents.api.agents.react_agent import ReActAgent +from flink_agents.api.core_options import AgentExecutionOptions from flink_agents.api.execution_environment import AgentsExecutionEnvironment from flink_agents.api.resource import ( ResourceDescriptor, @@ -53,6 +54,9 @@ def main() -> None: env = StreamExecutionEnvironment.get_execution_environment() agents_env = AgentsExecutionEnvironment.get_execution_environment(env) + # limit async request to avoid overwhelming ollama server + agents_env.get_config().set(AgentExecutionOptions.NUM_ASYNC_THREADS, 2) + # Add Ollama chat model connection and notify shipping manager tool to be used # by the Agent. agents_env.add_resource( diff --git a/python/flink_agents/examples/quickstart/workflow_multiple_agent_example.py b/python/flink_agents/examples/quickstart/workflow_multiple_agent_example.py index 81350285..09df650c 100644 --- a/python/flink_agents/examples/quickstart/workflow_multiple_agent_example.py +++ b/python/flink_agents/examples/quickstart/workflow_multiple_agent_example.py @@ -27,6 +27,7 @@ from pyflink.datastream.window import TumblingProcessingTimeWindows from pyflink.table import DataTypes, Schema, StreamTableEnvironment, TableDescriptor from pyflink.table.expressions import col +from flink_agents.api.core_options import AgentExecutionOptions from flink_agents.api.execution_environment import AgentsExecutionEnvironment from flink_agents.api.resource import ResourceType from flink_agents.examples.quickstart.agents.custom_types_and_resources import ( @@ -105,6 +106,9 @@ def main() -> None: env=env, t_env=t_env ) + # limit async request to avoid overwhelming ollama server + agents_env.get_config().set(AgentExecutionOptions.NUM_ASYNC_THREADS, 2) + # Add Ollama chat model connection to be used by the ReviewAnalysisAgent # and ProductSuggestionAgent. agents_env.add_resource( 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 e338e81b..ed81e5fe 100644 --- a/python/flink_agents/examples/quickstart/workflow_single_agent_example.py +++ b/python/flink_agents/examples/quickstart/workflow_single_agent_example.py @@ -21,6 +21,7 @@ from pyflink.common import Duration, WatermarkStrategy from pyflink.datastream import StreamExecutionEnvironment from pyflink.datastream.connectors.file_system import FileSource, StreamFormat +from flink_agents.api.core_options import AgentExecutionOptions from flink_agents.api.execution_environment import AgentsExecutionEnvironment from flink_agents.api.resource import ResourceType from flink_agents.examples.quickstart.agents.custom_types_and_resources import ( @@ -47,6 +48,9 @@ def main() -> None: env = StreamExecutionEnvironment.get_execution_environment() agents_env = AgentsExecutionEnvironment.get_execution_environment(env) + # limit async request to avoid overwhelming ollama server + agents_env.get_config().set(AgentExecutionOptions.NUM_ASYNC_THREADS, 2) + # Add Ollama chat model connection to be used by the ReviewAnalysisAgent. agents_env.add_resource( "ollama_server",
