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: 3:00am Wed UTC / 11:00am Wed Beijing / 7:00pm Tue US Pacific (PST)
• 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-11-11

• Flink Agents 0.4.0 Release

  • Released on October 30. Thanks to everyone who contributed, tested, and voted: Release announcement

• Flink Agents 1.0.0 — Must-have Progress
  Priorities: 1.0.0 brainstorming and proposed scope.

  • Distinguishing responses from multiple requests

    • [api][java][python] Propagate user context from request events to responses #1352 Merged.

  • Decoupling checkpointing from Agent execution

    • [runtime][java] Checkpoint in-flight actions without draining workers #1354 Merged.

  • State compatibility

    • Cross-release restoration test infrastructure and the first at-rest scenario are merged.
      • [runtime] Add cross-release state migration test for ActionExecutionOperator #1341 Merged.
    • Java/Python APIs now support a stable Agent operator UID.
      • [api][java][python] Support a stable UID for the agent operator #1356 Merged.
    • Pending Action/Event restoration coverage and the explicit upgrade path that skips the old ActionState journal remain follow-up work.

• Other Community Progress

  • Feature

    • Model Routing

      • Java Decision Model routing strategy: [api][plan][java] Add a decision-model routing strategy for MODEL_ROUTER #1330 Merged.
      • Python per-model attempt refactoring and rule-based/custom routing: [python][plan] Split chat model action into per-model attempts #1357, [api][plan][python] Support rule-based and custom model routing #1362 Merged.
      • YAML model router declarations:
        • [api][java][python] Declare model routers in YAML #1375 Updated after review, waiting for next review.
      • Quality-triggered escalation:
        • [api][plan][java] Quality-triggered escalation for model routing #1363 Under review, waiting for update.

    • Multimodal provider integrations

      • Anthropic image/document Tool results: [integrations][java][python][docs] Send images and documents in tool results to Anthropic #1331 Merged.
      • OpenAI Responses image/document Tool results: [integrations][java][docs] Send images and documents in tool results through the OpenAI Responses API #1364 Merged.
      • Amazon Bedrock multimodal user input: [integration][java] Send user images, documents, video and audio to Amazon Bedrock #1367 Merged.
      • Gemini multimodal Tool results:
        • [integrations][java][docs] Send images, audio, video and documents in tool results to Gemini #1370 Under review, waiting for update.
      • DashScope multimodal models:
        • [api][integrations][java][python] Support DashScope multimodal models #1374 Waiting for review.

    • PostgreSQL pgvector

      • [integrations][java] Add PostgreSQL pgvector vector store #1143 Merged.

    • Flink batch workflows

      • Complete pending work before key switches, avoiding dropped outputs with the batch keyed-state backend.
      • [runtime][java] Complete batch workflows before key switches #1172 Merged.

    • MCP discovery at operator startup

      • [runtime][java][python] Discover MCP tools and prompts at operator startup #1373 Approved, waiting for merge.

    • Unified Future scheduling and Tool execution

      • [api][plan][runtime][java] Unify Future scheduling and tool execution #1348 Updated after review, waiting for next review.

  • Bug Fix or Minor Improvement

    • 10 PRs merged

      • ActionState identity, Sub-Agent fault propagation/router inheritance, and input admission limits — 5 PRs
      • Legacy configuration loading, flat agent keys, and YAML precedence — 3 PRs
      • Failed YAML resource registration and unsupported annotation targets — 2 PRs

    • Parallel Action lifecycle and metrics

      • [runtime] Fix lifecycle and metric bookkeeping gaps in parallel action execution #1224 Under review, waiting for update.

    • Skill download and extraction limits

      • [runtime][java][skills] Bound download and extraction size #1091 Changes requested.

  • Tech debt / Infra

    • 5 PRs merged
      • Superseded CI cancellation, PyArrow shutdown, and routing recovery test fixes — 3 PRs
      • Development/review guidance and ResourceContext test utilities — 2 PRs

• To be discussed: 1.0.0 Timeline

  • Proposed schedule:
    • Code freeze: January 15, 2027
    • Release: January 30, 2027

2026-10-28

• Flink Agents 0.4.0 release
  • The release vote is open. Please help validate the release candidate and vote.
  • Expected vote close: October 29.
  • Target announcement: October 30, subject to a successful vote and completion of release preparation.
• Flink Agents 1.0.0 brainstorming Planning Flink Agents 1.0 - Brainstorming #1327
• Discussion
  • Community sync time: Which slot works better for everyone?
    • Option A: 10:00 Beijing / 18:00 US Pacific on the previous day (PST).
    • Option B: 11:00 Beijing / 19:00 US Pacific on the previous day (PST).
    • Confirm whether to keep Beijing time fixed and adjust Pacific time seasonally.
  • Skip the next sync on November 4?
    • Some of us will be attending Current. Would everyone be okay with skipping this sync and sharing updates asynchronously?
    • Please let us know if there is a topic that would benefit from a live discussion.

2026-10-21

• Focus: Flink Agents 0.4 walkthrough and release readiness

• Time Plan

  • Feature freeze: October 15
    • Older-JDK Sub-agent support and Decision Model support: exception deadline October 22
  • October 21–25: Full walkthrough of documentation, examples, and functionality
  • October 26–30: Prepare release artifacts and release notes, run the release vote
  • Target release: October 30

• Highlight Features

  • API review and refactoring
    • [Tech Debt][Umbrella] Review and refine Flink Agents APIs for 0.4 #1055 Completed: 17/17 sub-issues closed
      • Chat calls from Actions: [api][runtime][java][python] Add event-backed chat calls from actions #1220 Merged
      • Unified Trace Log: [api][runtime][python] Replace Event Log with unified Trace Log #1219 Merged
  • Sub-agent framework
    • Older-JDK support: [runtime] Support subgraph execution on the non-coroutine parallel engine #1299 Under review; target October 22
    • YAML support: [api][docs] Support YAML subagents and clarify the YAML reference #1269 Merged
    • Documentation and example improvements: [docs] Improve the Sub-Agents guide #1268 and [runtime][python][docs] Fix multi-agent examples and clarify sub-agent usage #1287 Merged

• API

  • Decision Model support
    • [api][java][python] Add DecisionModel resources and Event/Action calls #1264 and [docs] Add decision model entries to the resource, event, and cross-language indexes #1300 Merged
  • Structured output
    • User guide: [doc] Add a structured output user guide #1252 Merged
    • Schema compatibility and fallback improvements: [integrations][java] List each enum constant by its Jackson-serialized value in native schemas #1260, [integrations][java][python] Skip native structured output for a Map, JsonNode or dict field #1265, [api][java][python] Render a flat RowTypeInfo output schema as JSON Schema in the ReAct Agent prompt #1270, [python][integrations] Raise a clear error for an unrenderable output schema in the Ollama connection #1276, and [api][python][integrations] Share the native output model helper across chat model connections #1277 Merged

• Documentation

  • [Doc][Umbrella] Restructure and improve documentation for 0.4 #1225 Completed: 10/10 tasks closed
  • [docs] Clarify API and language choices #1257, [docs] Improve Built-in ReAct Agent usage documentation #1259, [docs] Clarify Tool Use injection and parallel-call guidance #1261, [docs] Restructure the observability chapter #1262, [docs] Improve Agent core concepts, Actions, and Events guides #1263, [api][docs] Support YAML subagents and clarify the YAML reference #1269, [docs] Improve Setup and the Quickstart user journey #1271, [docs] Document coding-agent Skill usage and refresh homepage navigation #1273, [docs] Consolidate resource guidance and improve Calling LLMs documentation #1274, and [docs] Improve consistency and configuration guidance #1284 Merged

• Walkthrough and Release Validation

  • [Doc][Umbrella] Walk through documentation and validate documented functionality for 0.4 #1283: October 21–25 walkthrough
    • Validate documentation correctness, cross-page consistency, and runnable examples
    • Contributors are welcome to join and report findings under the umbrella issue
  • Fixes already merged
    • Documentation, examples, and vector-store contracts: [hotfix][docs][api] Correct Calling LLMs, Vector Search and ReAct Agent to match the code #1278, [hotfix][integrations][python][docs] Align vector stores with their declared contracts #1280, [docs] Document the successive Python job limitation on a session cluster #1282, [docs] Fix release-branch source links and the Apple Silicon setup note #1285, and [docs] Fix non-runnable shared chat model example in the YAML API page #1297
    • Release artifacts now include the JDK 21 continuation runtime: [release][dist] Build release artifacts with JDK 21 and keep JDK 21 classes in thin JARs #1295
    • Bash parser and async worker interruption fixes: [hotfix][plan] Upgrade tree-sitter to 0.26.6 #1293 and [runtime][java] Keep worker lock ownership when an async call leaves the interrupt flag set #1298
  • Open findings
    • YAML MCP server declarations: [api][plan][java][python] Fix MCP server declarations in YAML #1303
    • Execution guards and Operations guidance: [runtime][python][docs] Fix execution guards and observability gaps in Operations guidance #1305
    • ActionStateStore divergence detection during multi-Action replay: [runtime] Fix ActionStateStore divergence detection for multi-action replay #1306
    • Memory documentation: [docs] Correct memory documentation #1307
    • Setup, multi-Agent Quickstart, and Flink integration: [Doc] Walkthrough findings for Setup, multi-Agent Quickstart and Flink integration #1308

TODO: Revisit the community sync schedule ahead of the end of daylight saving time in the US

2026-10-14

• Focus: Flink Agents 0.4 readiness ahead of the October 15 feature freeze

• Time Plan

  • Feature freeze: September 15 → October 15
  • Target release: September 30 → October 30
  • Proposed remaining schedule
    • October 15–20: Complete documentation and address known issues
    • October 21–25: Full walkthrough of documentation, examples, and functionality
    • October 26–30: Prepare release artifacts and release notes, run the release vote

• Highlight Features

  • API review and refactoring
    • [Tech Debt][Umbrella] Review and refine Flink Agents APIs for 0.4 #1055: 15/17 sub-issues completed
    • Chat calls from Actions
      • [api][runtime][java][python] Add event-backed chat calls from actions #1220 Under review
    • Unified Trace Log
      • [api][runtime][python] Replace Event Log with unified Trace Log #1219 First review round completed; follow-up review ongoing
  • Sub-agent framework
    • Core implementation: [api][plan][runtime][python] Support registering an Agent as an in-process internal sub-agent #1138, [api][runtime][python] Support running a ReActAgent as a general-purpose sub-agent #1206, [runtime][java] Avoid async-pool self-deadlock in internal sub-agent await (#1213) #1237, and [api][plan][runtime] Use generic resource descriptors for sub-agents #1242 Merged
    • Support for older JDK versions is under development; target: October 22
    • Documentation is being completed

• API

  • Multimodal model invocation
    • [integration][java][python] Send user images to Ollama #1178, [integration][java][python] Reject media blocks in providers that send text only #1186, and [api][java][python] Add raw-bytes factories for media blocks #1207 Merged
  • Structured output
    • [api][integrations][java][python] Ask each connection whether it could apply a schema natively #1129, [api][plan][integrations][java][python] Apply an agent output schema natively on the final response #1215, and [integrations][java] List Jackson enum values in OpenAI, Azure and Anthropic native schemas #1247 Merged
    • User guide [doc] Add a structured output user guide #1252 waiting for review
  • Decision Model support: [Feature] Support decision models in Flink Agents #1243
    • Under development; target: October 22

• Documentation

  • [Doc][Umbrella] Restructure and improve documentation for 0.4 #1225: 1/10 tasks completed
    • [docs] Restructure documentation navigation and guides for 0.4 #1244 Merged

• Discussion: 0.4 scope and feature freeze exceptions

  • Proposed scope
    • Include the planned 0.4 goals, critical bug fixes, and highlight features, including Sub-agent functionality and Decision Model support
    • Defer additional features and ecosystem integrations to the next release, such as pgvector support and multimodal support for more providers
  • Proposed deadline exceptions
    • Extend the deadline for older-JDK Sub-agent support and Decision Model support to October 22
    • Keep October 15 as the feature freeze date for other work

• Discussion: Release cadence

  • The current release intervals are too long for an Agent framework
    • Timely capabilities such as Skills, Sub-agents, and JEV should reach users when ready, rather than wait for a fixed release cycle
    • Users may wait months for a feature, discover bugs after trying it, and then face another long wait for fixes
  • We agreed to move toward more frequent, on-demand releases
    • Release when useful features or important fixes are ready, without accumulating several months of changes
  • To make this sustainable, we need to reduce release overhead
    • Keep the main branch reasonably stable and releasable
      • Merge features together with their documentation
      • Strengthen CI/CD and automated validation to catch regressions early and reduce manual release checks
    • Automate release preparation and repetitive publishing steps while preserving the required Apache release review and voting process

2026-09-30

• Contributions toward Flink Agents 0.4

  • Highlight

    • API review
      • [Tech Debt][Umbrella] Review and refine Flink Agents APIs for 0.4 #1055 umbrella issue remains open with sub-issues; please report newly discovered API problems there
        • [api][plan][java][python] Represent terminal chat failures in response events #1149 and [plan][java][python] Unify function schemas and argument validation #1176 Merged
        • [api][plan][java][python] Support direct declaration of cross-language actions #1159 Updated after review, waiting for next review
    • Java durable execution below JDK 21
      • [api][runtime] Support parallel action execution on JDK < 21 #1147 Merged
    • Sub-agent framework
      • [api][plan][python] Expose sub-agents to chat models as callable tools #1114 and [api][plan][runtime][python] Rebuild registered sub-agent setups from descriptors #1132 Merged
      • [api][plan][runtime][python] Support registering an Agent as an in-process internal sub-agent #1138 Updated, waiting for review and CI

  • Must

    • Multimodal model invocation
      • [api] Introduce multimodal content blocks #1060, [api][java][python] Align multimodal message contracts and safe logging #1163, and [integration][java][python] Send multimodal user messages through OpenAI Chat Completions #1164 Merged
      • [integration][java][python] Send user images to Ollama #1178 Waiting for review
    • Structured output
      • [api][integrations][java][python] Ask each connection whether it could apply a schema natively #1129 Under review, waiting for update

• Other Contributions

  • Feature

    • Model Routing
      • [api][plan][java] Validate router candidates and default model at declaration #1151 Merged
    • Checkpoint-aligned Kafka action-state cleanup
      • [runtime][api][python] Add checkpoint-aligned Kafka action-state cleanup #1101 Merged
    • OpenTelemetry GenAI exporter for Agent Traces
      • [integration][observability] Add OpenTelemetry GenAI exporter for Agent Traces (Phase 1) #1160 Updated after review, waiting for observability review

  • Bug Fix or Minor Improvement

    • 6 PRs Merged
      • Cross-language event, reference, and durable replay correctness (3 PRs)
      • Provider history propagation and retrieval validation (3 PRs)
    • Action-state durability and recovery
      • [runtime][java] Reuse saved Kafka action results after recovery #1161 Updated after review, waiting for next review and CI fix
      • [runtime][java] Preserve pending Fluss action state across checkpoints #1175 Draft
      • [runtime][java] Surface Kafka action-state send failures #1177 Waiting for review
    • Batch workflow completion
      • [runtime][java] Complete batch workflows before key switches #1172 Waiting for review

  • Tech debt / Infra

    • 1 PR Merged
      • Milvus CI image availability fix (1 PR)
    • Action recovery model alignment
      • [Tech Debt] align action recovery model #1155 Approved, waiting for merge

2026-09-23

• Contributions toward Flink Agents 0.4

  • Highlight

    • API review
      • [Tech Debt][Umbrella] Review and refine Flink Agents APIs for 0.4 #1055 umbrella issue remains open with sub-issues; please report newly discovered API problems there
        • [api][runtime][java][python] Add composable durable futures #1127 Merged
        • [api][plan][java][python] Represent terminal chat failures in response events #1149 Waiting for review
        • [Discussion][Observability] Replace Event Log with a Unified Trace Log #1146 Waiting for discussion
    • Java durable execution below JDK 21
      • [api][runtime] Support parallel action execution on JDK < 21 #1147 Under review, waiting for update
    • Sub-agent framework
      • [api][plan][python] Expose sub-agents to chat models as callable tools #1114 Updated after review, waiting for next review
      • [api][plan][runtime][python] Rebuild registered sub-agent setups from descriptors #1132 Waiting for review
      • [api][plan][runtime][python] Support registering an Agent as an in-process internal sub-agent #1138 Updated after review, with runtime design discussion ongoing

  • Must

    • Multimodal model invocation
      • [api] Introduce multimodal content blocks #1060 Under review, waiting for update
    • Structured output
      • [api][java][python] Name the model the capability predicate judges #1128 Merged
      • [api][integrations][java][python] Ask each connection whether it could apply a schema natively #1129 Under review, waiting for update
    • Observability and metrics
      • [runtime][plan][python] Add built-in operational metrics #955 Merged

• Other Contributions

  • Feature

    • Model Routing
      • [docs] Add Model Routing user documentation #1124 Merged
    • OpenAI embedding model and PostgreSQL pgvector
      • [integrations][java] Add OpenAI embedding model #1126 Merged
      • [integrations][java] Add PostgreSQL pgvector vector store #1143 Waiting for review
    • Checkpoint-aligned Kafka action-state cleanup
      • [runtime][api][python] Add checkpoint-aligned Kafka action-state cleanup #1101 Waiting for review

  • Bug Fix or Minor Improvement

    • 2 PRs Merged
      • Fail-fast validation for vector-store queries and retry policies (2 PRs)
    • Skill archive resource limits
      • [runtime][java][skills] Bound download and extraction size #1091 Updated after review, waiting for next review

  • Tech debt / Infra

    • 2 PRs Merged
      • Vector-store async cleanup and API parser test coverage (2 PRs)

2026-09-16

• Contributions toward Flink Agents 0.4

  • Highlight

    • API review
      • [Tech Debt][Umbrella] Review and refine Flink Agents APIs for 0.4 #1055 umbrella issue:
        • [API][Tool] Align Java and Python Tool outcome contracts #1074 merged
    • Java durable execution below JDK 21
      • [Feature][runtime] Support parallel action execution on JDK < 21 #1119 tracking issue opened
    • Sub-agent framework
      • [api][plan][python] Expose sub-agents to chat models as callable tools #1114 Under review, waiting for update and conflict resolution

  • Must

    • Multimodal model invocation
      • [api] Introduce multimodal content blocks #1060 Under review, waiting for update and conflict resolution
    • Structured output
      • [integrations][python] Apply DashScope native structured output #1090, [integrations][bedrock] Apply Bedrock native structured output #1097, [integrations][gemini] Apply Gemini native structured output #1098, [integrations][watsonx] Support watsonx.ai native structured output #1117, and [integrations][java] Share POJO JSON Schema generation across Ollama, Gemini, Bedrock and watsonx #1120 Merged
    • Observability and metrics
      • [runtime][plan][python] Add built-in operational metrics #955 Approved, waiting for conflict resolution and merge

• Other Contributions

  • Feature

    • Model Routing
      • [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) #1042 Merged
      • [docs] Add Model Routing user documentation #1124 Waiting for review
    • Automatic MemoryRef resolution
      • [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. #950 Merged
    • Checkpoint-aligned Kafka action-state cleanup
      • [api][runtime][python] Add opt-in Kafka tombstones for pruned action state #885 Merged
      • [runtime][api][python] Add checkpoint-aligned Kafka action-state cleanup #1101 Waiting for review
    • OpenAI embedding model
      • [integrations][java] Add OpenAI embedding model #1126 Waiting for review

  • Bug Fix or Minor Improvement

    • 8 PRs Merged
      • Runtime cancellation and execution-mode safeguards (2 PRs)
      • Action-state identity and Python bridge lifecycle fixes (4 PRs)
      • Provider finish-reason preservation (2 PRs)
    • Skill archive resource limits
      • [runtime][java][skills] Bound download and extraction size #1091 Under review, waiting for update

  • Tech debt / Infra

    • 3 PRs Merged
      • E2E and test-fixture reliability (2 PRs)
      • Milvus CI image fix (1 PR)
    • Distribution dependency isolation
      • [dist] Shade and relocate kafka-clients and jackson in flink-agents-dist #1110 Under review, waiting for update

2026-09-09

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

  • Code freeze moved to October 15
  • Release moved to October 30

• Contributions toward Flink Agents 0.4

  • Highlight

    • API review
      • [Tech Debt][Umbrella] Review and refine Flink Agents APIs for 0.4 #1055 umbrella issue remains open with initial sub-issues
      • [API][Tool] Align Java and Python Tool outcome contracts #1074 Updated after review, waiting for next review
    • Sub-agent framework
      • [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API #938 Merged

  • Must

    • Multimodal model invocation
      • [api] Introduce multimodal content blocks #1060 Waiting for review
    • Structured output
      • [integrations][gemini] Cover buildConfig with unit tests #1096 Merged
      • [integrations][python] Apply DashScope native structured output #1090 Under review, waiting for update
      • [integrations][bedrock] Apply Bedrock native structured output #1097 Waiting for review
      • [integrations][gemini] Apply Gemini native structured output #1098 Waiting for review and conflict resolution
    • Observability and metrics
      • [runtime][plan][python] Add built-in operational metrics #955 Updated after review, waiting for next review and conflict resolution
    • AI-assisted code review
      • [infra] Add a guide for AI-assisted PR implementation descriptions #1073 Merged

• Other Contributions

  • Feature

    • Model Routing
      • [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) #1042 Under review, waiting for update
    • Event attachments with automatic MemoryRef wrapping and resolution
      • [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. #950 Updated after review, waiting for next review
    • Checkpoint-aligned Kafka action-state cleanup
      • [api][runtime][python] Add opt-in Kafka tombstones for pruned action state #885 Updated after review, waiting for next review

  • Bug Fix or Minor Improvement

    • 3 PRs Merged
      • Secure URL skill sources (1 PR)
      • Runtime cancellation and Kafka initialization fixes (2 PRs)
    • Action-state identity and runtime correctness
      • [runtime] Cover the cross-loader action key failure and document action renaming #1094 Updated after review, waiting for next review
      • [runtime] Preserve typed Flink key identity in action state #1100 Waiting for review
      • [runtime] Reject RuntimeExecutionMode.BATCH with the default batch state backend #1104 Waiting for review
    • Embedded Python interpreter concurrency
      • [runtime][java] Make embedded Python interpreters thread-confined #1092 Waiting for review and conflict resolution
    • Skill archive resource limits
      • [runtime][java][skills] Bound download and extraction size #1091 Updated after review, waiting for next review and conflict resolution
    • Anthropic response completion semantics
      • [integrations][anthropic][java][python] Preserve Anthropic finish reason #1107 Waiting for review

  • Tech debt / Infra

    • 1 PR Merged
      • Cross-language CI stabilization (1 PR)

2026-09-02

• Reporting window: 2026-08-26 to 2026-09-02

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

• Contributions toward Flink Agents 0.4

  • Highlight

    • API review
      • [Tech Debt][Umbrella] Review and refine Flink Agents APIs for 0.4 #1055 umbrella issue opened, serval sub issues created
      • [API][Tool] Align Java and Python Tool outcome contracts #1074 Waiting for review
    • Sub-agent framework
      • [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API #938 Updated after review

  • Must

    • Multimodal model invocation
      • [api] Introduce multimodal content blocks #1060 Waiting for review
    • Structured output
      • [integrations][java][python] Apply Ollama native structured output #981, [integrations][plan] Handle finish_reason in OpenAI-family connections #1040, and [api][integrations][java][python] Raise a clear error for an output schema that cannot be rendered #1046 Merged
    • Observability and metrics
      • [runtime][plan][python] Add built-in operational metrics #955 and [api][java][python] Record embedding token usage metrics #1047 Under review, waiting for update
    • AI-assisted code review
      • [infra] Add a guide for AI-assisted PR implementation descriptions #1073 Under review, waiting for update

  • If Possible

    • Parallel tool execution
      • [Feature] Parallel Tool Call Execution #926 Merged

• Other Contributions

  • Feature

    • Model Routing
      • [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) #1042 Under review
    • MemoryRef auto resolve
      • [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. #950 Under review, waiting for update
    • Dry-run / replay mode
      • [Feature] Dry-run / replay mode for validating agent behavior against production-shaped state before deploying #1066 Design discussion Design proposal for #1066: dry-run / replay via savepoints #1069 opened
    • Durable human approval
      • [Feature] Human-in-the-loop approval as a first-class, checkpointed Action primitive #1067 Design discussion suggested

  • Bug Fix or Minor Improvement

    • 11 PRs Merged
      • Security hardening across main and release branches (5 PRs)
      • Chat-model and API validation compatibility (3 PRs)
      • Runtime lifecycle and memory correctness (3 PRs)
    • Secure skill sources
      • [api][runtime][java][python] Require HTTPS and add digest pinning for URL skill sources #1005 Under review, waiting for update
    • Runtime cancellation and action-state correctness
      • [plan][runtime] Do not retry or persist interrupted chat calls on cancellation #1071 Under review, waiting for update

  • Tech debt / Infra

    • 4 PRs Merged
      • Test-suite consolidation and reliability fixes (3 PRs)
      • CI action upgrades (1 PR)

• Discussion: Flink Agents 0.4 schedule

  • Current plan
    • Feature freeze: September 15
    • Release: September 30
  • Current progress
    • API review has just started
    • The API compatibility mechanism and asynchronous Java durable execution below JDK 21 have not started
    • Multimodal model invocation, the sub-agent framework, and dynamic AgentPlan updates are still in progress
  • Proposal
    • Move the feature freeze to October 15
    • Move the release to October 30

2026-08-26

• Contributions toward Flink Agents 0.4

  • Highlight

    • Sub-agent framework
      • [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API #938 Updated after review, waiting for next review

  • Must

    • Multimodal model invocation
      • [Discuss][API] Multimodal content parts in ChatMessage #1031 Design discussion opened and under review
    • Structured output
      • [integrations][java][python] Apply Anthropic native structured output #965 Merged
      • [integrations][java][python] Apply Ollama native structured output #981, [integrations][plan] Handle finish_reason in OpenAI-family connections #1040, and [api][integrations][java][python] Raise a clear error for an output schema that cannot be rendered #1046 Under review, waiting for update
    • Observability
      • [api][runtime][python] Add Agent Trace recording to Event Log #924 Merged
      • [runtime][plan][python] Add built-in operational metrics #955 Updated, waiting for review
      • [api][java][python] Record embedding token usage metrics #1047 Waiting for review
    • AI-assisted code review
      • [infra] Add a dist and dependency review guide #1022 Merged

  • If Possible

    • Conditional triggers for Actions
      • [docs] Document Action trigger conditions #977 Merged
    • Parallel tool execution
      • [Feature] Parallel Tool Call Execution #926 Under review, waiting for update and conflict resolution

• Other Contributions

  • Feature

    • Model Routing
      • [api][plan][runtime][examples] Add pluggable in-chat model routing (MODEL_ROUTER) #964 Merged
      • [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) #1042 Waiting for review
    • IBM watsonx.ai integration
      • [java][python] IBM watsonx.ai chat model integration #922 Merged
    • Automatic MemoryRef resolution
      • [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. #950 Updated after review, waiting for next review and conflict resolution
    • Checkpoint-aligned Kafka action-state cleanup
      • [Feature] Add checkpoint-aligned cleanup for Kafka action state #1034 Opened as a follow-up to [api][runtime][python] Add opt-in Kafka tombstones for pruned action state #885

  • Bug Fix or Minor Improvement

    • 13 PRs Merged

      • Provider, schema, and dependency compatibility fixes (5 PRs)
      • Recovery and runtime correctness fixes (4 PRs)
      • Elasticsearch filtering and documentation improvements (4 PRs)

    • Security hardening

      • [api][runtime][java][python] Require HTTPS and add digest pinning for URL skill sources #1005 Under review, waiting for update

    • Durable ActionState lifecycle

      • [api][runtime][python] Add opt-in Kafka tombstones for pruned action state #885 Under review, waiting for update

    • Long-term memory isolation

      • [runtime][api] Scope long-term memory operations to the action that obtained the memory set #1002 Under review, waiting for update

    • Runtime resource cleanup

      • [hotfix][runtime][python] Close every component when an earlier close fails #987 Approved, waiting for conflict resolution and merge
      • [runtime][python] Release bridge-owned Pemja objects during cleanup #944 Waiting for [hotfix][runtime][python] Close every component when an earlier close fails #987 and conflict resolution / update

    • Chat model compatibility and validation

      • [python] Reject unknown constructor arguments on chat model connections/setups #1051, [integrations][anthropic] Stop sending rejected sampling parameters #1037, and [integrations][anthropic] Update the stale default model to claude-sonnet-4-6 #1039 Under review, waiting for update

  • Tech debt / Infra

    • 9 PRs Merged
      • Checkpoint-recovery, long-term-memory, and Elasticsearch test coverage (3 PRs)
      • Build, RAT validation, CI, recovery-version, and Bats fixes (5 PRs)
      • Deprecated Azure AI Inference integration removal (1 PR)

2026-08-12

• Security Hardening

  • [Bug][security][skills] Protect URL skill sources with secure transport and integrity verification #1003 Protect URL skill sources with secure transport and integrity verification
  • [Bug][security][bash] Constrain redirect targets and execution-changing environment assignments #1004 Constrain Bash redirect targets and execution-changing environment assignments

• Contributions toward Flink Agents 0.4

  • Must
    • Structured output
      • [integrations][java][python] Apply Ollama native structured output #981 Waiting for review
      • [integrations][java][python] Apply Anthropic native structured output #965 Under review, waiting for update
    • Observability
      • [api][runtime][python] Add memory events for agent memory observability #887 Merged
      • [api][runtime][python] Add Agent Trace recording to Event Log #924 Updated after review, waiting for next review
      • [runtime][plan][python] Add built-in operational metrics #955 Draft updated
    • Sub-agent framework
      • [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API #938 Under review, waiting for update and conflict resolution
    • Flink Agents Dev Skills
      • [ci] Guard the coding-agent skill's bundled YAML schema against drift #969 Merged
  • If Possible
    • Conditional triggers for Actions
      • [runtime][java][python] Add CEL Action condition filtering #821 Merged
      • [docs] Document Action trigger conditions #977 Under review, waiting for update
    • Parallel tool execution
      • [Feature] Parallel Tool Call Execution #926 Under review, waiting for update

• Other Feature Contributions

  • vLLM integration
    • [integration] Add out of the box vLLM chat model support for Java and Python #945 Merged
  • Model routing
    • [api][plan][runtime][examples] Add pluggable in-chat model routing (MODEL_ROUTER) #964 Under review, waiting for update
  • IBM watsonx.ai integration
    • [java][python] IBM watsonx.ai chat model integration #922 Under review, waiting for update and conflict resolution
  • [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. #950 Updated after review, waiting for next review and conflict resolution

• Bug Fix or Minor Improvement

  • [integrations][openai] Preserve provider refusals in the Python message converter #952, [integration][anthropic][python] Keep token usage on non-tool_use responses #959, [docs] Fix two Python snippets that do not run and an inaccurate schema parity claim #972, and [hotfix][runtime] Aggregate close failures across the Exception/Error boundary #974 Merged
  • [integration][openai] Align default parameters for openai chat model between java and python #883, [runtime][python] Release bridge-owned Pemja objects during cleanup #944, [integrations][openai] Let provider exceptions reach the caller unwrapped #989, and [hotfix][vector-store][java] Update Elasticsearch filters documentation #997 Updated after review, waiting for next review
  • [runtime][python] Refresh imports for new dependency generations #943 and [hotfix][runtime][python] Close every component when an earlier close fails #987 Under review, waiting for update
  • [integrations][vector-store][java] Apply Elasticsearch KNN filters before selecting neighbors #1001 and [runtime][api] Scope long-term memory operations to the action that obtained the memory set #1002 Waiting for review

• Tech debt / Infra

  • [e2e] Add nightly e2e test for submitting examples to flink standalone cluster #708, [infra] Add a docs-only review guide #971, [e2e][python] Stabilize standalone nightly example tests #975, [test][python] Use the registered checkpoint interval key in the Python e2e tests #978, [infra] Invoke the build scripts' Python tools through the interpreter #979, [infra] Guard uv in e2e.sh and fix the pytest log level in ut.sh #986, [dist] Add missing NOTICE entries for bundled dependencies #991, [infra] Include model in AI provenance #993, and [infra] Update main version to 0.4-SNAPSHOT #994 Merged
  • [test][python] Assert long-term memory content instead of an exact LLM item count #984, [integrations][azureai] Remove the deprecated Azure AI Inference integration #988, [infra] Add an api/ contract review guide #961, [hotfix] Add help handling to build script #995, and [hotfix][tools] Report RAT validation dependencies correctly #996 Updated after review, waiting for next review
  • [e2e] Add a checkpoint-recovery test for restored Python state #992 and [ci] Name the tools script test job after the command it runs #1000 Waiting for review

2026-08-05

• Contributions toward Flink Agents 0.4

  • Must
    • Structured output
      • [integrations][openai] Apply OpenAI native structured output #919 and [integrations][java][python] Apply Azure OpenAI native structured output #930 Merged
      • [integrations][java][python] Apply Anthropic native structured output #965 Waiting for review
    • Observability
      • [api][runtime][python] Add minimal Event lineage #923 Merged
      • [api][runtime][python] Add memory events for agent memory observability #887 Under review, waiting for update
      • [api][runtime][python] Add Agent Trace recording to Event Log #924 Updated after review, waiting for next review and conflict resolution
    • Flink Agents Dev Skills
      • [infra] Add a coding-agent development skill #918 Merged
      • [ci] Guard the coding-agent skill's bundled YAML schema against drift #969 Waiting for review
  • If Possible
    • Conditional triggers for Actions
      • [runtime][java][python] Add CEL Action condition filtering #821 Under review, waiting for update
    • Parallel tool execution
      • [Feature] Parallel Tool Call Execution #926 Under review, waiting for update

• Other Feature Contributions

  • Model routing
    • [api][plan][runtime][examples] Add pluggable in-chat model routing (MODEL_ROUTER) #964 Waiting for review
  • Sub-agent framework
    • [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API #938 Under review, with design discussion ongoing
  • [java][python] IBM watsonx.ai chat model integration #922 Under review, waiting for follow-up updates and conflict resolution
  • [integration] Add out of the box vLLM chat model support for Java and Python #945 and [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. #950 Waiting for review

• Bug Fix or Minor Improvement

  • [python] warn when an action declares a return value #835, [docs] Use a current GA API version in the Azure OpenAI examples #935, [hotfix][runtime] Close the Kafka consumer when the producer fails to close #948, [hotfix][java][python] Release skill repositories on any load failure and remove dead code #951, [dist][runtime] Use Flink-provided Log4j dependencies #954, [integration][gemini] Synthesize a tool-call id when the API omits functionCall.id #960, [api][yaml] Add aliases for six unaliased resource implementations #962, and [docs] Correct the documented provider for the azure YAML alias #963 Merged
  • [runtime][python] Refresh imports for new dependency generations #943, [runtime][python] Release bridge-owned Pemja objects during cleanup #944, [integrations][openai] Preserve provider refusals in the Python message converter #952 and [integration][anthropic][python] Keep token usage on non-tool_use responses #959 Waiting for review
  • [integration][openai] Align default parameters for openai chat model between java and python #883 and [api][runtime][python] Add opt-in Kafka tombstones for pruned action state #885 Waiting for update

• Tech debt / Infra

  • [infra] Surface the ASF generative-AI disclosure in the PR template #933, [hotfix] Ignore the local directories check-license.sh creates #934, and [infra] Add a Python-Java bridge review guide #957 Merged
  • Bump org.apache.logging.log4j:log4j-core from 2.25.3 to 2.25.4 in /e2e-test #967 Under review
  • [infra] Add an api/ contract review guide #961 Waiting for review

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 [api][runtime][python] Add opt-in Kafka tombstones for pruned action state #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, [api][runtime][python] Add opt-in Kafka tombstones for pruned action state #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
    • [api][runtime][python] Add opt-in Kafka tombstones for pruned action state #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
    • [api][runtime][python] Add opt-in Kafka tombstones for pruned action state #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
    • #612 Completed
• Other contributions
  • #633
    • Merged
  • #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.
    • #629
      • Under review
    • #609
      • Reviewed, awaiting update.
    • #599
      • Waiting for review
  • If possible
    • #545
      • Waiting for review
    • #612
      • #614 Merged
• Other contributions
  • #566
    • Merged
  • #132
    • Merged
  • #611
    • Merged
  • #603
    • Waiting for review

2026-04-08

• Flink Agents 0.3.0
  • Must
    • Agent Skills Integration
      • #596 Updated, waiting for review
    • #609
      • Waiting for review
    • #571
      • Merged
    • #555
      • #599 Waiting for review
  • If possible
    • #547
      • Merged
    • #545
      • Waiting for review
    • #612
      • #600 Merged
      • #614 Under review
• Other contributions
  • #560
    • Merged
  • #566
    • Under review
  • #132
    • Under review
  • #611
    • Under review
  • #603
    • Waiting for review

2026-04-01

• Flink Agents 0.2.1
  • Released
• Flink Agents 0.3.0
  • Must
    • Agent Skills Integration
      • #565 Design in discussion
      • #596 Waiting for update PR
    • #542
      • Waiting for update PR
    • #571
      • Updated, waiting for review
    • #555
      • #599 WIP
  • If possible
    • #547
      • Updated, waiting for review
    • #545
      • PR waiting for review
    • #543
      • Design reached consensus
• Other contributions
  • #578
    • Merged
  • #581
    • Merged
  • #560
    • PR in review
  • #566
    • PR in review
  • #132
    • Doc PR waiting for review

2026-03-25

• Flink Agents 0.2.1
  • Finalizing
• Flink Agents 0.3.0
  • Must
    • Agent Skills Integration
      • #565 Design in discussion
      • Implementation WIP @wenjin272
    • #542
      • Waiting for update PR
    • #571
      • Waiting for update PR
    • #555
      • Waiting for PR
  • If possible
    • #547
      • Waiting for update PR
    • #545
      • PR waiting for review
    • #543
      • Design reached consensus
  • Other contributions
    • #578
      • PR in review
    • #560
      • PR in review
    • #566
      • PR waiting for review
    • #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
    • #565
    • Cross-language actions & events
      • #561
        • PR in review
    • #542
      • Design reached consensus, waiting for updating PR
    • #555
      • Design reached consensus, waiting for updating PR
    • #571
      • WIP
  • If possible
    • #547
      • PR in review
    • #545
      • PR waiting for review
    • #543
      • Design in discussion.
  • Other contributions
    • #556
    • #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] #519
    • Package size is still larger than the 100MB limit. Trying to download the jar files on installation.
  • #532
  • #539
• Flink Agents 0.3.0
  • Must
    • #553
    • #536
    • #552
    • Cross-language actions & events
      • #424
    • #555
  • If possible
    • #543
    • #547
    • #545
  • Other contributions
    • #534
    • #542
    • #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] #519
  • #532
  • #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
    • #516

2026-02-18

• Canceled - Happy Chinese New Year~!

2026-02-11

• Flink Agents 0.2 - Released!
• Flink Agents 0.3
  • #537
  • #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~! #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
      • #350 @wenjin272
      • #351 @wenjin272
    • Integration
      • #368 @xli1996
      • #374 @xli1996
    • #443 @Sxnan
    • #382 @GreatEugenius
    • #393 @wenjin272
    • #437 @Sxnan
    • #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
      • #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
  • #389
  • #348
    • Implementation completed, docs missing @wenjin272
  • #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
    • #345
    • #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
  • #348 @wenjin272
    • remaining 1 PR + docs
  • Java API
    • #321 @twosom
      • doc PR in review, very close to merging
    • #334 @xli1996 @yanand0909
  • #352 @GreatEugenius
    • ChatModel - completed
    • EmbeddingModel - completed
    • VectorStore - in progress
    • MCP- not yet
  • #395
  • #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
    • #345
    • #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