Community Sync - 2026

[xintongsong]

There's a community sync for discussing developing progress, technical designs and community issues about Flink Agents.

Everyone is welcome to join.

• Schedule: 2:30pm Wed UTC
• Google Calendar
  • The event might re-scheduled or skipped sometimes. It's strongly recommended to subscribe to the google calendar for update notifications.
• Google Meet

The agenda of the next sync and minutes of previous syncs will be posted below. Please feel free to propose new topics for the agenda.

Previous Discussions

• Community Sync - 2025 #66

---

2026-07-29

• 0.3.1: released on July 25

• Flink Agents 0.4.0 roadmap: Planning Flink Agents 0.4 #862

  • Feature freeze: September 15
  • Release: September 30

• Contributions toward Flink Agents 0.4

  • Must
    • Structured output
      • [api][python] Add explicit output schema parameter to the chat path (structured-output foundation) #843 Merged
      • [integrations][openai] Apply OpenAI native structured output #919 Under review, waiting for update
      • [integrations][java][python] Apply Azure OpenAI native structured output #930 Waiting for review
    • Observability
      • [api][python][java] Track embedding token usage metrics #870 Merged
      • [api][runtime][python] Add memory events for agent memory observability #887, [api][runtime][python] Add minimal Event lineage #923, and [api][runtime][python] Add Agent Trace recording to Event Log #924 Under review, waiting for update
    • Flink Agents Dev Skills
      • [infra] Add a coding-agent development skill #918 Waiting for conflict resolution and update
  • If Possible
    • Conditional triggers for Actions
      • [runtime][java][python] Add CEL Action condition filtering #821 Updated after review, waiting for next review
    • Parallel tool execution
      • [Feature] Parallel Tool Call Execution #926 Under review, waiting for update

• Release-cycle exploration not tied to the 0.4 release

  • AI-assisted code review
    • [infra] Add change-type review guides with runtime/ template #911 Merged
    • [infra] Surface the ASF generative-AI disclosure in the PR template #933 Waiting for review

• Other Contributions

  • Feature
    • IBM watsonx.ai integration
      • [java][python] IBM watsonx.ai chat model integration #922 Waiting for review
  • Bug Fix or Minor Improvement
    • [fix] Fix ReActAgent failure when output schema is null. #838, [docs][integration] Document Gemini chat model integration #898, [bug] [python] Propagate config model reconstruction errors in Action deserialize #921 and [e2e][java] Validate ReActAgent output without schema #927 Merged
    • [python] warn when an action declares a return value #835 Updated after review, waiting for next review
    • [integration][openai] Align default parameters for openai chat model between java and python #883 and [runtime] send Kafka tombstones on state pruning for durable log compaction #885 Waiting for update
    • [docs] Use a current GA API version in the Azure OpenAI examples #935 Waiting for review
  • Tech debt / Infra
    • [hotfix] Ignore the local directories check-license.sh creates #934 Waiting for review

• Design Discussions

  • 0.4 targets
    • Sub-agent framework: [Feature] Sub-agent Resource for Flink Agents - Framework part #909
    • Observability and tracing: [Discuss][Observability] OpenTelemetry GenAI export for Agent Traces (follow-up to #900) #929
  • Other topics
    • Model routing: [Discussion] Pluggable model routing — API & design (PR #852 follow-up) #897
    • Dedicated vLLM support: [Feature] Add VLLM_CONNECTION to the ChatModel out-of-the-box #928
    • Provider and cross-language follow-ups: [integrations] Azure AI Inference SDK is deprecated and retires on 2026-08-26 #931 and [Tech Debt] Non-happy-path response handling diverges between Java and Python in OpenAI-family connections #936

2026-07-22

• Contributions
  • Feature
    • Structured output
      • [api][python] Add explicit output schema parameter to the chat path (structured-output foundation) #843 Updated after review, waiting for next review
      • [integrations][openai] Apply OpenAI native structured output #919 Waiting for review
    • Support conditional triggers for Actions
      • [runtime][java][python] Add CEL Action condition filtering #821 Under review, waiting for update
    • Metrics
      • [api][runtime][python] Propagate metric groups to cross-language resources #860 Merged
      • [api][python][java] Track embedding token usage metrics #870 Waiting for resolving conflicts
    • [api][runtime][python] Add memory events for agent memory observability #887 Under review, waiting for update
  • Bug Fix or Minor Improvement
    • [api][java] Substitute prompt placeholders in a single pass #908, [python] Tolerate Java tool params without a description #915, and [integration][anthropic] Don't assume the first content block is text #916 Merged
    • [docs][integration] Document Gemini chat model integration #898 Updated after review, waiting for next review
    • [integration][openai] Align default parameters for openai chat model between java and python #883, [runtime] send Kafka tombstones on state pruning for durable log compaction #885, and [bug] [python] Propagate config model reconstruction errors in Action deserialize #921 Under review, waiting for update
  • Tech debt / Infra
    • [infra] Add CLAUDE.md importing AGENTS.md #910 Merged
    • [infra] Add change-type review guides with runtime/ template #911 Waiting for review
    • [infra] Add a coding-agent development skill #918 Under review, waiting for update
• Design Discussions
  • Sub-agent framework: [Feature] Sub-agent Resource for Flink Agents - Framework part #909 opened; [Discussion] Supervisor + Sub-Agent Orchestration: Concrete Multi-Agent Use Cases for Event-Driven Agents #660 converged on a same-job, same-operator built-in as the first step
  • Observability: [Discussion] Agent observability: tracing & evaluation beyond metrics + event log #710 proposed minimal Event lineage; [Discussion][Observability 1/2] Recording Agent Traces in the Event Log #900 and [Discussion][Observability 2/2] Built-in Operational Metrics for Flink Agents #901 refined trace and metrics contracts
  • Model routing: [Discussion] Pluggable model routing — API & design (PR #852 follow-up) #897 continued around runtime events, per-loop routing state, recovery, and caching
  • Parallel tool execution: Parallel Tool Call Execution #855 Reach an agreement
• • Flink Agents 0.3.1
    • 7.20: vote
    • 7.23: close vote
    • 7.24: release
• Flink Agents 0.4.0 roadmap: Planning Flink Agents 0.4 #862
  • code freeze: September 15
  • release: September 30

2026-07-15

• Contributions
  • Feature
    • [api][python] Add explicit output schema parameter to the chat path (structured-output foundation) #843 Updated after review, design direction being refined
    • Support conditional triggers for Actions
      • [runtime][java][python] Add CEL Action condition filtering #821 Under review, waiting for update
    • [api][python][java] Track embedding token usage metrics #870 Updated after review, waiting for next review
    • [api][runtime][python] Add memory events for agent memory observability #887 Under review, waiting for update
    • [Feature][Java] Move MCP resource discovery to runtime #639 Waiting for conflict resolution / update
  • Bug Fix or Minor Improvement
    • [integration][openai] Update stale default model gpt-3.5-turbo to gpt-4o-mini #906 Merged
    • [api][java] Substitute prompt placeholders in a single pass #908 Under review
    • [docs][integration] Document Gemini chat model integration #898 Under review, waiting for update
    • [runtime] send Kafka tombstones on state pruning for durable log compaction #885 Under review, waiting for update
    • [integration][openai] Align default parameters for openai chat model between java and python #883 Under review, waiting for update
    • [api][plan][python] Use request-scoped metric groups for chat token metrics #861 Under review, waiting for update
    • [api][runtime][python] Propagate metric groups to cross-language resources #860 Under review, waiting for update
  • Tech debt / Infra
    • [Tech Debt] Avoid using reflection to load implementation classes of resources during the compilation phase #879 Merged
    • [python] Backfill remote test coverage ahead of local execution path removal #881 and [python] Remove the Python local execution path #882 Merged
    • [tools] Update install.sh for Flink Agents 0.3.0 and Python 3.12 #888 and [tools] Keep install plan edits consistent #899 Merged
    • [docs] Clarify review policy #890 and [infra] Add AGENTS.md version freshness check #903 Merged
    • [ci] Retry Ollama install and propagate download failures #891, [ci] Bound the runtime of the integration-test jobs #892, [test][python] Avoid forking MCP test server from PyFlink process #896, and [ci] Pin Ollama to the AVX2 CPU build in the integration jobs #904 Merged
• Design Discussions
  • Model routing: [Discussion] Pluggable model routing — API & design (PR #852 follow-up) #897 opened; [api][routing] Pluggable in-chat LLM routing (ChatModelRouter + RoutingStrategy) #852 remains a prototype/reference
  • Observability: [Discussion][Observability 1/2] Recording Agent Traces in the Event Log #900 Agent Trace and [Discussion][Observability 2/2] Built-in Operational Metrics for Flink Agents #901 operational metrics opened
  • Parallel tool execution: Parallel Tool Call Execution #855 discussion continued
• Flink Agents 0.4.0 roadmap: Planning Flink Agents 0.4 #862
• Preparing Flink Agents 0.3.1

2026-07-08

• Contributions
  • Feature
    • [api][python] Add explicit output schema parameter to the chat path (structured-output foundation) #843 Updated after review, waiting for next review
    • Support conditional trigger for Actions
      • [runtime][java][python] Add CEL Action condition filtering #821 Updated after review, under review
    • [Feature] Support tool parameter injection #854 Merged
    • [dist] Add Flink 2.3 distribution and make it the default #856 Merged
    • [api][python][java] Track embedding token usage metrics #870 Updated after review, under review
    • [api][routing] Pluggable in-chat LLM routing (ChatModelRouter + RoutingStrategy) #852 Design discussion suggested, PR kept as prototype/reference
  • Bug Fix or Minor Improvement
    • [python] Admit bytes in the Python memory value contract #846 Merged
    • [python] Remove PyFlink gateway fallback from AgentConfigOptions #867 Merged
    • [api][runtime][test] Add @JsonCreator to built-in event subclasses for ActionStateSerde durable recovery #869 Merged
    • [ci] Use maintained 'temurin' distribution for setup-java #873 Merged
    • [runtime] Binary serde for MemoryUpdate values via versioned Kryo envelope #874 Merged
    • [hotfix] Propagate action task Errors from mailbox #880 Merged
    • [integration][openai] Align default parameters for openai chat model between java and python #883 Waiting for review
    • [runtime] send Kafka tombstones on state pruning for durable log compaction #885 Waiting for review
  • Tech debt / Infra
    • [infra] Add AGENTS.md #878 Merged
    • [Tech Debt] Avoid using reflection to load implementation classes of resources during the compilation phase #879 Under review, waiting for update
    • [python] Backfill remote test coverage ahead of local execution path removal #881 Waiting for review
    • [python] Remove the Python local execution path #882 Waiting for review
    • [api][runtime][python] Propagate metric groups to cross-language resources #860 Under review
    • [Feature][Java] Move MCP resource discovery to runtime #639 Waiting for conflict resolution / update
• Flink Agents 0.4.0 roadmap: Planning Flink Agents 0.4 #862

2026-07-01

• Flink Agents 0.3.0: released https://flink.apache.org/2026/06/19/apache-flink-agents-0.3.0-release-announcement/
• Contributions
  • Feature
    • [api][python] Add explicit output schema parameter to the chat path (structured-output foundation) #843 Waiting for review
    • [feature][integration][java] Add built-in Google Gemini chat model integration #718 Merged
    • Support conditional trigger for Actions
      • [api][java][python] Introduce EventType constants and unify Action trigger entry #756 Merged
      • [runtime][java][python] Add CEL Action condition filtering #821 Waiting for review
    • [Feature] Support tool parameter injection #854 Under review
    • [dist] Add Flink 2.3 distribution and make it the default #856 Under review
  • Bug Fix or Minor Improvement
    • [python] Admit bytes in the Python memory value contract #846 Waiting for review
    • [Bug] Action-scoped metrics can be recorded under the wrong action for cached resources #859 Under review
  • Tech debt
    • [python] warn when an action declares a return value #835 Under review
    • [api][runtime][python] Propagate metric groups to cross-language resources #860 Under review
• Flink Agents 0.4.0 roadmap: Planning Flink Agents 0.4 #862

2026-06-17

• Flink Agents 0.3.0
  • Pre-release tasks：[Umbrella] Release Flink Agents 0.3.0 #728 Done
    • [Feature] Support Flink 2.3 #833 is moved to next version 0.4
  • Target Time Plan:
    • 06-08: Complete manual verification: Done
    • 06-16: Complete issue resolving & start voting: Done https://lists.apache.org/thread/0ynstq0szq0b22r362p5llkylt2l8brj
    • 06-22 : Release
• Other contributions
  • Feature
    • [dependency] Bump flink to 1.20.5 and 2.1.3 #842 Done
    • [api][python] Add explicit output schema parameter to the chat path (structured-output foundation) #843 Waiting for review
    • [feature][integration][java] Add built-in Google Gemini chat model integration #718 Waiting for review
    • [Feature][Java] Move MCP resource discovery to runtime #639 Waiting for review
    • Support triggering Actions by Event Field
      • [api][java][python] Introduce EventType constants and unify Action trigger entry #756 Waiting for review
      • [runtime][java][python] Add CEL Action condition filtering #821 Waiting for review
  • Bug Fix or Minor Improvement
    • [Bug] Python memory can persist Pemja-incompatible values and fail after state backend restore #723 Done
    • [python] Admit bytes in the Python memory value contract #846 Waiting for review
    • [fix] Fix ReActAgent failure when output schema is null. #838 Waiting for update
  • Tech debt
    • [api] Remove dead no-arg getExecutionEnvironment() referencing a non-existent LocalExecutionEnvironment #848 Done
    • [python] warn when an action declares a return value #835 Under review
    • [e2e] Add nightly e2e test for submitting examples to flink standalone cluster #708 Under review

2026-06-10

• Flink Agents 0.3.0
  • Pre-release tasks：[Umbrella] Release Flink Agents 0.3.0 #728
    • Manual verification and correspond fix
      • [Release] Check issues and PRs are correctly labeled #731 Done
      • [Release] Check commits' corresponding issues / PRs are properly labeled and documentations are completed #732 Done
      • [Release] Manual verification following the user documentation #729 Done
      • [dist] Update bundled dependency NOTICE and licenses for 0.3 #832 Merged
    • Remaining Blocker Issues
      • [Tech Debt] Update flink version after 1.20.5 & 2.1.3 release. #692
      • [Feature] Support Flink 2.3 #833
      • [Release] Prepare release announcement for Flink Agents 0.3.0 #730 Preparing
      • [Bug] Python memory can persist Pemja-incompatible values and fail after state backend restore #723
        • [python] Normalize built-in tool-call context for checkpoint safety #828 Merged
        • PR2 validator and doc: Preparing
      • [docs][examples] Add parallel LLM quickstart and examples for multi-action fan-out #830 Under Review
  • Target Time Plan: Delayed by 4 days
    • 06-08: Complete manual verification
    • 06-16 (06-12): Complete issue resolving & start voting
    • 06-22 (06-18): Release
• Other contributions
  • Test Stability Optimization
    • [ci] Refactor CI of test cases in integration module #702
    • [test][runtime] Strengthen live-LLM e2e tests with structured tool-invocation assertions #722
    • [python] Remove Python-3.10-only Ollama auto-pull block in integration tests #831
  • Bug Fix or Minor Improvement
    • [Bug] Stale processing keys in union list state can be snapshotted by non-owner subtasks #824
    • [Tech Debt] Add unit tests for tool schema conversion utilities (api/tools/utils.py) #814
    • [api][test] Simplify cross-language Java action declaration and add e2e coverage #827

2026-06-03

• Flink Agents 0.3.0 feature freeze
• [Umbrella] Release Flink Agents 0.3.0 #728
• Target Time Plan
  • 06-08: Complete manual verification
  • 06-12: Complete issue resolving & start voting
  • 06-18: Release

2026-05-27

• Flink Agents 0.3.0
  • Must
    • [docs][examples] Add Agent Skills documentation and quickstart example #707 In review
    • [doc] Add YAML API documentation and quickstart example. #705 In review
  • If possible
    • [Feature] Support dynamic refresh of MCP tools and prompts #608 In review
• Other contributions
  • Merged
    • [Feature][Integration][Java] Add built-in support for Azure OpenAI Chat Model #695
    • [Doc] Add documentation for Amazon Bedrock, Amazon OpenSearch, and Amazon S3 Vectors integrations #680
    • [tools]Import Wizard for Installation Setup #599
  • Pending for review
    • [Feature] Support TTL on ShortTermMemory #657
    • [Feature][Python] Implement EventListener in python sdk #688
    • Doc built in actions #669
    • [api][plan][runtime] Separate prompt arguments from message extra_args in BaseChatModelSetup.chat() #698
    • [ci] Refactor CI of test cases in integration module #702
    • [e2e] Add nightly e2e test for submitting examples to flink standalone cluster #708

2026-05-20

• Flink Agents 0.3.0
  • Must
    • Agent Skills Integration
      • [api][runtime] Extend agent skill loading repository. #655 Merged
    • [tools]Import Wizard for Installation Setup #599 Under review
    • YAML API
      • [api][python] Introduce YAML API for declaring agents #670 Merged
      • [api][java] Introduce YAML API for declaring agents #690 Merged
    • [Feature][Integration][Java] Add Milvus vector store integration #663 Merged
  • If possible
    • [Feature] Support dynamic refresh of MCP tools and prompts #608 Awaiting review
• Other contributions
  • Merged
    • [Feature][Java] Add EventListener config #640
    • [Feature] Support Fluss as ActionStateStore backend #628
    • [runtime] Add comprehensive tests for ActionExecutionOperator manager classes  #659
    • [hotfix] Move chat-model os.environ mutations out of module scope in e2e tests #689
    • [hotfix] Make Ollama embedding test actually run in CI #686
    • [api] Specify model in ChatModelSetup (Java + Python) #685
    • [FLINK-AGENTS][api] Fix Kryo deserialization failure for Event classes with immutable lists #677
    • [FLINK-AGENTS][integrations] Fix OpenSearchVectorStore for Amazon OpenSearch Serverless #678
    • [FLINK-AGENTS][api] Add ResourceName constants for AWS integrations #679
  • Awaiting review
    • [Feature] Support TTL on ShortTermMemory #657
    • [Feature][Python] Implement EventListener in python sdk #688
    • [Feature][Integration][Java] Add built-in support for Azure OpenAI Chat Model #695
    • Doc built in actions #669
    • [Doc] Add documentation for Amazon Bedrock, Amazon OpenSearch, and Amazon S3 Vectors integrations #680

2026-05-13

• Flink Agents 0.3.0
  • Must
    • Agent Skills Integration
      • [api][integration] Support agent skills in python #596 Merged
      • [api][runtime] Support agent skills in java #650 Merged
      • [api][runtime] Extend agent skill loading repository. #655 Awaiting review
    • [Feature] Support Mem0 as Long-Term Memory backend. #617 Completed
    • [runtime] Support per-event-type configurable log levels for event log #609 Merged
    • [Feature] Support cross language unified event. #424 Merged
    • [tools]Import Wizard for Installation Setup #599 Awaiting update
    • Cross Language Unified Event #631 Merged
    • [feature] Enable EventLog display in WebUI by default #638 Merged
    • Introduce YAML API #662 Design in Discussion
    • [Feature][Integration][Java] Add Milvus vector store integration #663 Reviewed
  • If possible
    • [Tech Debt] Refactor ActionExecutionOperator into focused manager classes #545 Merged
    • [Feature] Support dynamic refresh of MCP tools and prompts #608 Awaiting review
• Other contributions
  • [runtime] Fix prune state corner cases around checkpoints #603 Merged
  • [Feature][Java] Add EventListener config #640 Awaiting update
  • [Feature] Support Fluss as ActionStateStore backend #628 Under review
  • [Feature] Support TTL on ShortTermMemory #657 Awaiting review
  • [runtime] Add comprehensive tests for ActionExecutionOperator manager classes  #659 Awaiting review
  • [Discussion] Supervisor + Sub-Agent Orchestration: Concrete Multi-Agent Use Cases for Event-Driven Agents #660 In Discussion

2026-04-29

• Flink Agents 0.3.0
  • Must
    • Agent Skills Integration
      • [api][integration] Support agent skills in python #596 Merged
      • [api][java] Support Agent Skill in java #591 WIP
    • Mem0 Integration
      • [api][runtime] Support Mem0 based Long-Term Memory in Python. #629 Merged
      • [Feature][Java] Support Mem0 Long-Term Memory backend in Java. #619 WIP
      • [Doc] Introduce Mem0 based Long-Term Memory #637 Awaiting review
    • [runtime] Support per-event-type configurable log levels for event log #609
      • Reviewed two round, awaiting update.
    • [tools]Import Wizard for Installation Setup #599
      • Under review
    • Cross Language Unified Event #631
      • Reviewed three round, awaiting update.
    • [feature] Enable EventLog display in WebUI by default #638
      • Reviewed, awaiting update
  • If possible
    • [Tech Debt] Refactor ActionExecutionOperator into focused manager classes #545
      • Reviewed two round, awaiting update
• Other contributions
  • [Feature][Java] Add EventListener config #640 Awaiting review
  • [Feature] Support dynamic refresh of MCP tools and prompts #608 Awaiting review
  • [Feature] Support Fluss as ActionStateStore backend #628
    • Reviewed two round, awaiting update

2026-04-22

• Flink Agents 0.3.0
  • Must
    • Agent Skills Integration
      • [api][integration] Support agent skills in python #596
        • Updated, awaiting review.
    • [api][runtime] Support Mem0 based Long-Term Memory in Python. #629
      • Updated, awaiting review.
    • [runtime] Support per-event-type configurable log levels for event log #609
      • Reviewed two round, awaiting update.
    • [tools]Import Wizard for Installation Setup #599
      • Reviewed, awaiting update
    • Cross Language Unified Event #631
      • Updated, awaiting review
  • If possible
    • [Tech Debt] Refactor ActionExecutionOperator into focused manager classes #545
      • Reviewed two round, awaiting update
    • [Feature] Track durable execution reconciler work #612 Completed
• Other contributions
  • [Feature] JsonParseException in ChatModelAction when LLM returns JSON wrapped in Markdown code blocks #633
    • Merged
  • [hotfix] Fix argument name mismatch in PythonVectorStore. #635
    • Merged
  • [runtime] Fix prune state corner cases around checkpoints #603
    • Waiting for review

2026-04-15

• Flink Agents 0.3.0
  • Must
    • Agent Skills Integration
      • [api][integration] Support agent skills in python #596
        • Reviewed, awaiting update.
    • [api][runtime] Support Mem0 based Long-Term Memory in Python. #629
      • Under review
    • [runtime] Support per-event-type configurable log levels for event log #609
      • Reviewed, awaiting update.
    • [tools]Import Wizard for Installation Setup #599
      • Waiting for review
  • If possible
    • [Tech Debt] Refactor ActionExecutionOperator into focused manager classes #545
      • Waiting for review
    • [Feature] Track durable execution reconciler work #612
      • [runtime][python] Add Python durable reconciler support #614 Merged
• Other contributions
  • [Tech Debt] Guard resource name consistency with CI #566
    • Merged
  • [Feature] Support OpenAI latest Response API #132
    • Merged
  • [python][integrations] Add Tongyi embedding model integration #611
    • Merged
  • [runtime] Fix prune state corner cases around checkpoints #603
    • Waiting for review

2026-04-08

• Flink Agents 0.3.0
  • Must
    • Agent Skills Integration
      • [api][integration] Support agent skills in python #596 Updated, waiting for review
    • [runtime] Support per-event-type configurable log levels for event log #609
      • Waiting for review
    • [runtime] Support async execution for cross language resources. #571
      • Merged
    • [Feature] Enhance the quickstart experience #555
      • [tools]Import Wizard for Installation Setup #599 Waiting for review
  • If possible
    • [Tech Debt] Refactor AgentPlan & ResourceCache #547
      • Merged
    • [Tech Debt] Refactor ActionExecutionOperator into focused manager classes #545
      • Waiting for review
    • [Feature] Track durable execution reconciler work #612
      • [api][runtime][java] Add durable reconcile support with reconciler callables #600 Merged
      • [runtime][python] Add Python durable reconciler support #614 Under review
• Other contributions
  • [Feature] Add support for custom job name in Flink Agents Job execution #560
    • Merged
  • [Tech Debt] Guard resource name consistency with CI #566
    • Under review
  • [Feature] Support OpenAI latest Response API #132
    • Under review
  • [python][integrations] Add Tongyi embedding model integration #611
    • Under review
  • [runtime] Fix prune state corner cases around checkpoints #603
    • Waiting for review

2026-04-01

• Flink Agents 0.2.1
  • Released
• Flink Agents 0.3.0
  • Must
    • Agent Skills Integration
      • Agent Skills Integration Design #565 Design in discussion
      • [api][integration] Support agent skills in python #596 Waiting for update PR
    • [FLINK-AGENTS-541][api][runtime] Support per-event-type configurable log levels for event log #542
      • Waiting for update PR
    • [runtime] Support async execution for cross language resources. #571
      • Updated, waiting for review
    • [Feature] Enhance the quickstart experience #555
      • [tools]Import Wizard for Installation Setup #599 WIP
  • If possible
    • [Tech Debt] Refactor AgentPlan & ResourceCache #547
      • Updated, waiting for review
    • [Tech Debt] Refactor ActionExecutionOperator into focused manager classes #545
      • PR waiting for review
    • [Feature] Dynamic Runtime Loading and Refresh of MCP Tools and Prompts #543
      • Design reached consensus
• Other contributions
  • [Bug] Flink Agents Java MCPServer#listPrompts crashes(NullPointer) when required field is missing in prompt arguments #578
    • Merged
  • [runtime] Filter resumed currentProcessingKeys by subtask ownership a… #581
    • Merged
  • [Feature] Add support for custom job name in Flink Agents Job execution #560
    • PR in review
  • [Tech Debt] Guard resource name consistency with CI #566
    • PR in review
  • [Feature] Support OpenAI latest Response API #132
    • Doc PR waiting for review

2026-03-25

• Flink Agents 0.2.1
  • Finalizing
• Flink Agents 0.3.0
  • Must
    • Agent Skills Integration
      • Agent Skills Integration Design #565 Design in discussion
      • Implementation WIP @wenjin272
    • [FLINK-AGENTS-541][api][runtime] Support per-event-type configurable log levels for event log #542
      • Waiting for update PR
    • [runtime] Support async execution for cross language resources. #571
      • Waiting for update PR
    • [Feature] Enhance the quickstart experience #555
      • Waiting for PR
  • If possible
    • [Tech Debt] Refactor AgentPlan & ResourceCache #547
      • Waiting for update PR
    • [Tech Debt] Refactor ActionExecutionOperator into focused manager classes #545
      • PR waiting for review
    • [Feature] Dynamic Runtime Loading and Refresh of MCP Tools and Prompts #543
      • Design reached consensus
  • Other contributions
    • [Bug] Flink Agents Java MCPServer#listPrompts crashes(NullPointer) when required field is missing in prompt arguments #578
      • PR in review
    • [Feature] Add support for custom job name in Flink Agents Job execution #560
      • PR in review
    • [Tech Debt] Guard resource name consistency with CI #566
      • PR waiting for review
    • [Feature] Support OpenAI latest Response API #132
      • Doc PR waiting for review

2026-03-18

• Flink Agents 0.2.1
  • All blockers resolved, will start RC vote tomorrow
• Flink Agents 0.3.0
  • Must
    • Agent Skills Integration Design #565
    • Cross-language actions & events
      • Cross Language Unified Event #561
        • PR in review
    • [FLINK-AGENTS-541][api][runtime] Support per-event-type configurable log levels for event log #542
      • Design reached consensus, waiting for updating PR
    • [Feature] Enhance the quickstart experience #555
      • Design reached consensus, waiting for updating PR
    • [runtime] Support async execution for cross language resources. #571
      • WIP
  • If possible
    • [Tech Debt] Refactor AgentPlan & ResourceCache #547
      • PR in review
    • [Tech Debt] Refactor ActionExecutionOperator into focused manager classes #545
      • PR waiting for review
    • [Feature] Dynamic Runtime Loading and Refresh of MCP Tools and Prompts #543
      • Design in discussion.
  • Other contributions
    • [Feature][Java] Add OpenAI Responses API integration #556
    • [Feature] Add support for custom job name in Flink Agents Job execution #560
      • PR in review
• AI-Ops Demo
  • All set, waiting for 0.2.1 release
  • Repo: https://github.com/apache/flink-agents-demos
• Matyas Orhidi proposed to integrate Flink Agents with Flink K8s Operator, starting with the examples
• Flink Forward Asia Demo Plan
• Time slot for community sync

2026-03-11

• Canceled

2026-03-04

• Flink Agents 0.2.1
  • [Blocker] [Tech Debt] Reduce size of flink-agents wheel #519
    • Package size is still larger than the 100MB limit. Trying to download the jar files on installation.
  • [hotfix][mcp] Fix MCPTool Jackson deserialization by ignoring unknown properties #532
  • [FLINK-AGENTS] Fix Java agents failing to connect to MCP servers without prompt support (#538) #539
• Flink Agents 0.3.0
  • Must
    • [Feature] Support python 3.12 #553
    • Agent Skills Investigation #536
    • [Feature] Per-Event-Type Configurable Log Levels for Event Log #552
    • Cross-language actions & events
      • [Feature] Support cross language unified event. #424
    • [Feature] Enhance the quickstart experience #555
  • If possible
    • [Feature] Dynamic Runtime Loading and Refresh of MCP Tools and Prompts #543
    • [Tech Debt] Refactor AgentPlan & ResourceCache #547
    • [Tech Debt] Refactor ActionExecutionOperator into focused manager classes #545
  • Other contributions
    • [FLINK-AGENTS-523] Add Amazon Bedrock chat model and embedding model integrations #534
    • [FLINK-AGENTS-541][api][runtime] Support per-event-type configurable log levels for event log #542
    • [Feature] Support OpenAI latest Response API #132
• AI-Ops Demo
  • Video preparing.
  • Creating an apache/flink-agents-demos repository? For not only this demo, but hopefully more demos in future.

2026-02-25

• Flink Agents 0.2.1
  • [Blocker] [Tech Debt] Reduce size of flink-agents wheel #519
  • [hotfix][mcp] Fix MCPTool Jackson deserialization by ignoring unknown properties #532
  • [FLINK-AGENTS] Fix Java agents failing to connect to MCP servers without prompt support (#538) #539
• Flink Agents 0.3.0
  • Time Plan
    • Target: feature freeze May 31, release Jun 15
    • That's ~4 months after 0.2.0
    • Flink Forward Asia (Shenzhen) is planed late June or early July
  • Feature Plan
    • Planning Flink Agents 0.3 #516

2026-02-18

• Canceled - Happy Chinese New Year~!

2026-02-11

• Flink Agents 0.2 - Released!
• Flink Agents 0.3
  • Memory Framework Investigation #537
  • Agent Skills Investigation #536
• AI-Ops demo
  • WIP
  • Will post an informal version this week
• Skip next week

2026-02-04

• Flink Agents 0.2
  • RC1 in vote
  • Expected to release on 2.6 (Fri)
• AI-Ops demo
  • WIP
  • Publish as an opensource project - likely before the Chinese New Year vacation (2.15)
  • Demo video - Not sure if we can make it before the vacation. If not, around end of Feb.
• Flink Agents 0.3
  • Let's brainstorm~! Planning Flink Agents 0.3 #516

2026-01-28

• Flink Agents 0.2
  • Documentation - completed
  • Manual Test - completed
  • Known bugs & issues - no known blockers
  • Next
    • Help verify the documentation and codes
    • Help review the release announcement
    • Start RC vote - 2.2

2026-01-21

• Flink Agents 0.2
  • Feature Development - all completed
  • Documentation - by 1.25
    • Memory
      • [doc] Add documents for sensory memory #350 @wenjin272
      • [doc] Add documents for long-term memory #351 @wenjin272
    • Integration
      • [Feature][doc] Add document for built-in openai chat model support in java #368 @xli1996
      • [Feature] [doc] Add document for built-in anthropic chat model support in java #374 @xli1996
    • [Feature][doc] Update documentation for async & durable execution #443 @Sxnan
    • [Feature][doc] Add document on how to use cross-language resources #382 @GreatEugenius
    • [Feature] Add document for how to add dependency in pom for flink-agents project. #393 @wenjin272
    • [Feature][doc] Add guidelines for how to choose between java / python apis #437 @Sxnan
    • [Feature] [doc] Create a dedicated section for introducing MCP. #450 @wenjin272
  • Manual Tests - by 1.28
    • Manually walk through all the documentations, looking for:
      • Bugs
      • Inconsistent documentation
      • Potential experience improvements
  • Known bugs & issues - by 2.1
    • Pemja related - depend on Flink bumping Pemja version
      • [Bug] Flink Agents Example Fails with 'ModuleNotFoundError: No module named 'encodings'' in YARN Cluster Mode #306
  • Releasing - by 2.6
    • Release Announcement @xintongsong
    • Release notes (breaking changes list) @wenjin272
    • Building artifacts @wenjin272
    • RC vote

2026-01-14

• Flink Agents 0.2
  • Java API complement - completed
  • [Feature] Update release infra to support multi-jdk version #389
  • [Feature] Introduce Comprehensive Memory Management. #348
    • Implementation completed, docs missing @wenjin272
  • [Feature] Support Cross-Language Resource #352
    • ChatModel - completed
    • EmbeddingModel - completed
    • VectorStore - Python completed, Java in-progress @GreatEugenius
    • MCP - Python only, in-progress @istavrak
  • Async Execution
    • Python - completed
    • Java - in progress @Sxnan
  • Fine-Grained Durable Execution
    • Python - completed
    • Java - in progress @Sxnan
  • Some other enhancements @wenjin272
    • [Tech Debt] Support close method for Resource #345
    • [Feature] Support async execution for built-in actions #381
    • Avoid non-api dependencies for user jobs
• Feature Freeze - Jan 19 (Mon)
• TODO
  • Guidelines for choosing between Java and Python
  • Brainstorming for the next release cycle

2026-01-07

• Flink Agents 0.2
  • [Feature] Introduce Comprehensive Memory Management. #348 @wenjin272
    • remaining 1 PR + docs
  • Java API
    • [Feature][integration][Java] Java Implementation of Vector Store with Elasticsearch Support #321 @twosom
      • doc PR in review, very close to merging
    • [Feature] [api][Java] Add built-in mcp support for Java #334 @xli1996 @yanand0909
  • [Feature] Support Cross-Language Resource #352 @GreatEugenius
    • ChatModel - completed
    • EmbeddingModel - completed
    • VectorStore - in progress
    • MCP- not yet
  • [Feature] Support Multi-Version Flink for Flink Agents #395
  • [Feature] Update release infra to support multi-jdk version #389 - PR in review, very close to merging
  • Async Execution @Sxnan
    • Python - completed
    • Java - in progress
  • Fine-Grained Durable Execution @Sxnan
    • Python - completed
    • Java - in progress
  • Some other enhancements @wenjin272
    • [Tech Debt] Support close method for Resource #345
    • [Feature] Support async execution for built-in actions #381
    • Avoid non-api dependencies for user jobs
• Time Plan
  • Feature Freeze - Jan 19 (Mon), originally Jan 15
  • Documentation & Testing - Jan 19-31
  • Release - By Jan 31