apache/flink-agents

View on GitHub

Flink Agents is an Agentic AI framework based on Apache Flink

Stars: 454
Forks: 167
Open beginner issues: 0
Indexed issues: 57
Avg merge: 5d 1h
Merged PRs (30d): 46

Dominant language: Java
License: Apache-2.0
Last GitHub push: Sep 20, 2026
Latest indexed: Sep 14, 2026
Contributing guide: Contributing guide
Code of conduct: Code of conduct
Beginner labels: No beginner labels indexed

Beginner friendly Everything

Open All

50 open issues indexed

[Bug][api] VectorStoreQuery accepts a null or negative limit Open

apache/flink-agents#1145 · 1 assignee · Opened Sep 18, 2026
[Feature] Support cross-language subagent usage Open

feature priority/major

Difficulty 5/5 Over a week Newbie friendliness 35/100

apache/flink-agents#1141 · Opened Sep 18, 2026
[Feature] Support batch scheduling and parallel execution of subagents Open

feature priority/major

Difficulty 5/5 Over a week Newbie friendliness 25/100

apache/flink-agents#1140 · Opened Sep 18, 2026
[Feature] Support registering ReActAgent as a general-purpose subagent Open

feature priority/major

Difficulty 5/5 Over a week Newbie friendliness 25/100

apache/flink-agents#1139 · Opened Sep 18, 2026
[Feature] Support in-process internal sub-agent Open

feature priority/major

apache/flink-agents#1137 · 1 assignee · Opened Sep 18, 2026
[Umbrella][Feature] Subagent Resource Open

feature priority/major

Difficulty 5/5 Over a week Newbie friendliness 25/100

apache/flink-agents#1134 · Opened Sep 17, 2026
Add a @ModelRouterSetup annotation for declaring model routers inside an agent class Open

apache/flink-agents#1133 · 1 assignee · Opened Sep 17, 2026
[Bug][plan] sub-agent cannot be rebuilt on a remote task after plan serialization Open

bug fixVersion/0.4.0 priority/major

apache/flink-agents#1131 · 3 comments · 1 assignee · Opened Sep 17, 2026
[Tech Debt][API] Represent terminal chat failures in ChatResponseEvent Open

fixVersion/0.4.0 priority/major tech debt

apache/flink-agents#1130 · 1 assignee · Opened Sep 17, 2026
[Tech Debt][API][Event] Restore built-in event types at cross-language boundaries Open

fixVersion/0.4.0 priority/major tech debt

Difficulty 5/5 Over a week Newbie friendliness 45/100

apache/flink-agents#1125 · Opened Sep 16, 2026
[Tech Debt][API][Python Bridge] Move concrete Python resource wrappers to the Plan module Open

fixVersion/0.4.0 priority/major tech debt

apache/flink-agents#1121 · 2 comments · 1 assignee · Opened Sep 15, 2026
[Feature][runtime] Support parallel action execution on JDK < 21 Open

feature fixVersion/0.4.0 priority/major

apache/flink-agents#1119 · 1 comment · 1 assignee · Opened Sep 15, 2026
[Feature] Expose sub-agents to chat models as callable tools Open

feature fixVersion/0.4.0 priority/major

apache/flink-agents#1112 · 1 assignee · Opened Sep 10, 2026
[Tech Debt][runtime] Replace isDone() polling with completion-callback wakeup for suspended Java async actions Open

priority/major tech debt

apache/flink-agents#1109 · 2 comments · 1 assignee · Opened Sep 9, 2026
[Tech Debt][runtime][python][skills] Preserve skill-repository close failures Open

Difficulty 3/5 1-2 days Newbie friendliness 72/100

apache/flink-agents#1108 · 2 comments · Opened Sep 7, 2026
[integrations] Preserve finish_reason for Anthropic and Watsonx responses Open

feature

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/flink-agents#1106 · 1 comment · Opened Sep 6, 2026
[Feature] Add OpenAI embedding model (Java) Open

feature fixVersion/0.4.0 priority/major

apache/flink-agents#1103 · 1 comment · 1 assignee · Opened Sep 5, 2026
[Feature] Add PostgreSQL pgvector vector store (Java) Open

apache/flink-agents#1102 · 1 comment · 1 assignee · Opened Sep 5, 2026
[Tech Debt][API][Tool] Unify function-schema derivation and argument validation Open

fixVersion/0.4.0 priority/major tech debt

Difficulty 5/5 Over a week Newbie friendliness 35/100

apache/flink-agents#1093 · Opened Sep 3, 2026
[Tech Debt][API][Chat Model] Review the chat model invocation flow in custom Actions Open

fixVersion/0.4.0 priority/major tech debt

Difficulty 5/5 Over a week Newbie friendliness 35/100

apache/flink-agents#1086 · 1 assignee · Opened Sep 2, 2026
[Tech Debt][API][Action] Improve annotation-based cross-language Action declarations Open

fixVersion/0.4.0 priority/major tech debt

apache/flink-agents#1085 · 2 comments · 1 assignee · Opened Sep 2, 2026
[Bug][runtime] Durable action-state keys collide for distinct events with identical attributes Open

bug priority/major

Difficulty 5/5 Over a week Newbie friendliness 45/100

apache/flink-agents#1084 · 5 comments · Opened Sep 2, 2026
[Tech Debt][API][Flink Integration] Simplify Agent output materialization to DataStream and Table Open

fixVersion/0.4.0 priority/major tech debt

Difficulty 5/5 Over a week Newbie friendliness 35/100

apache/flink-agents#1080 · Opened Sep 1, 2026
[Bug][skills] Bound download and extraction size for URL skill sources Open

bug priority/major

Difficulty 4/5 3-5 days Newbie friendliness 52/100

apache/flink-agents#1072 · 2 comments · Opened Aug 30, 2026
[Feature] Human-in-the-loop approval as a first-class, checkpointed Action primitive Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

apache/flink-agents#1067 · 1 comment · Opened Aug 29, 2026
[Feature] Dry-run / replay mode for validating agent behavior against production-shaped state before deploying Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

apache/flink-agents#1066 · 2 comments · Opened Aug 29, 2026
[Feature] Per-agent token/cost budget guardrail (enforcement, not just reporting) Open

Difficulty 5/5 Over a week Newbie friendliness 35/100

apache/flink-agents#1065 · 2 comments · Opened Aug 29, 2026
[Feature] Cross-language (Java/Python) agent spec parity test harness Open

Difficulty 5/5 Over a week Newbie friendliness 35/100

apache/flink-agents#1064 · Opened Aug 29, 2026
[Umbrella] Pluggable model routing (MODEL_ROUTER): delivery status, Python parity, documentation, and follow-ups Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

apache/flink-agents#1062 · Opened Aug 28, 2026
[Feature] Multimodal content blocks in ChatMessage Open

feature priority/major

apache/flink-agents#1059 · 2 comments · 1 assignee · Opened Aug 28, 2026
[Tech Debt][API][ChatMessage] Review ChatMessage responsibilities and data model Open

fixVersion/0.4.0 priority/major tech debt

Difficulty 5/5 Over a week Newbie friendliness 25/100

apache/flink-agents#1056 · 1 assignee · Opened Aug 27, 2026
[Tech Debt][Umbrella] Review and refine Flink Agents APIs for 0.4 Open

fixVersion/0.4.0 priority/major tech debt

apache/flink-agents#1055 · 1 assignee · Opened Aug 27, 2026
[Feature] Add checkpoint-aligned cleanup for Kafka action state Open

feature priority/major

apache/flink-agents#1034 · 2 comments · 1 assignee · Opened Aug 21, 2026
[Tech Debt] Align Java and Python recovery model Open

priority/major tech debt

apache/flink-agents#1016 · 10 comments · 1 assignee · Opened Aug 16, 2026
[Bug] An output schema pydantic cannot render raises instead of taking the prompt fallback Open

bug priority/minor

Difficulty 4/5 3-5 days Newbie friendliness 55/100

apache/flink-agents#985 · 2 comments · Opened Aug 8, 2026
[Feature] OpenTelemetry GenAI exporter for Agent Traces (Phase 1: Java, spans-only) Open

feature priority/major

Difficulty 5/5 Over a week Newbie friendliness 35/100

apache/flink-agents#970 · Opened Aug 5, 2026
[Bug] Bounded workflows silently drop records in batch mode with multiple keys Open

bug priority/major

Difficulty 4/5 3-5 days Newbie friendliness 48/100

apache/flink-agents#939 · 1 comment · Opened Jul 30, 2026
[Feature] Apply structured output to an agent's final output only Open

feature priority/major

apache/flink-agents#912 · 5 comments · 1 assignee · Opened Jul 17, 2026
[Feature] Track token usage metrics for embedding models Open

feature priority/major

Difficulty 4/5 3-5 days Newbie friendliness 48/100

apache/flink-agents#858 · 2 comments · Opened Jun 25, 2026
[Feature][Python] Implement EventListener to align with Java SDK Open

feature fixVersion/0.4.0 priority/major

Difficulty 4/5 3-5 days Newbie friendliness 48/100

apache/flink-agents#687 · Opened May 18, 2026
[Feature] Shade and relocate third-party dependencies in flink-agents-dist to avoid classpath conflicts Open

feature fixVersion/0.4.0 priority/major

apache/flink-agents#652 · 1 comment · 1 assignee · Opened May 9, 2026
[Feature] Support dynamic refresh of MCP tools and prompts Open

feature priority/major

apache/flink-agents#608 · 1 assignee · Opened Apr 2, 2026
[Feature] Add OAuth2 Helper for native OAuth support for remote connections Open

feature priority/major

apache/flink-agents#607 · 1 assignee · Opened Apr 2, 2026
[Feature] Support MCP tools and prompts runtime discovery Open

feature fixVersion/0.4.0 priority/major

Difficulty 4/5 3-5 days Newbie friendliness 45/100

apache/flink-agents#606 · Opened Apr 2, 2026
[Tech Debt] [python] Remove setuptools<82 constraint after apache-flink upgrades to apache-beam>=2.66.0 Open

priority/major tech debt

Difficulty 3/5 1-2 days Newbie friendliness 35/100

apache/flink-agents#529 · 2 reactions · Opened Feb 10, 2026
[Feature] Support auto resolve memory reference for passing data across actions. Open

feature priority/major

apache/flink-agents#476 · 6 comments · 1 assignee · Opened Jan 26, 2026
[Feature] Dynamic load MCP tools and prompts in runtime. Open

feature fixVersion/0.4.0 priority/major

Difficulty 5/5 Over a week Newbie friendliness 35/100

apache/flink-agents#458 · 2 comments · Opened Jan 20, 2026
[Feature] [integration] [Java] Chroma vector store for Java Open

feature priority/major

apache/flink-agents#335 · 7 comments · 1 assignee · Opened Nov 21, 2025
[Feature] Support making use of the native capabilities of models for structure output. Open

feature priority/major

apache/flink-agents#280 · 9 comments · 1 assignee · Opened Oct 20, 2025
[Feature] Support built-in RAG agent Open

feature priority/major

Difficulty 5/5 Over a week Newbie friendliness 20/100

apache/flink-agents#144 · Opened Sep 6, 2025

apache/flink-agents

Get new issues in your inbox