Apache Flink Agents 0.2.1 发布公告

简介: Apache Flink Agents 0.2.1发布!修复3个关键缺陷(含MCP连接与Jackson反序列化问题),优化事件日志JSON输出、减小wheel包体积,并增强CI可观测性。推荐所有用户升级。支持OpenAI、Anthropic等多模型集成,附Demo演示智能运维能力。(239字)

Apache Flink 社区很高兴地宣布发布 Apache Flink Agents 0.2 系列的首个缺陷修复版本。

此版本包含 3 项缺陷和漏洞修复以及一些对Flink-Agents 0.2的小幅改进。下面列出了所有缺陷修复和改进内容(不包括构建基础设施和构建稳定性方面的改进)。如需查看完整变更列表,请参见:ISSUE

我们强烈建议所有用户升级到 Flink-Agents 0.2.1。

0.2.1 版本有哪些新变化?

Maven 依赖

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-agents-api</artifactId>
  <version>0.2.1</version>
</dependency>
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-agents-integrations-chat-models-ollama</artifactId>
    <version>0.2.1</version>
</dependency>
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-agents-integrations-chat-models-openai</artifactId>
    <version>0.2.1</version>
</dependency>
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-agents-integrations-chat-models-anthropic</artifactId>
    <version>0.2.1</version>
</dependency>
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-agents-integrations-chat-models-azureai</artifactId>
    <version>0.2.1</version>
</dependency>
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-agents-integrations-embedding-models-ollama</artifactId>
    <version>0.2.1</version>
</dependency>
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-agents-integrations-vector-stores-elasticsearch</artifactId>
    <version>0.2.1</version>
</dependency>
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-agents-integrations-mcp</artifactId>
    <version>0.2.1</version>
</dependency>

二进制文件

你可以在更新后的下载页面找到相关二进制文件。

PyPi

https://pypi.org/project/flink-agents/0.2.1/

发布说明

Release Notes - Flink-Agents - Version 0.2.1

Bug(缺陷修复)

[412] - 修复无法连接到不支持 prompts 的远程 MCP 服务器的问题

[538] - 修复 Java agents 无法连接到不支持 prompts 的 MCP 服务器的问题

[532] - 修复 MCPTool 的 Jackson 反序列化问题:忽略未知属性

Improvement(改进)

[568] - 支持事件日志以 pretty-printed JSON 格式输出

[519] - 减小 flink-agents wheel 包的体积

Technical Debt(技术债)

[96] - 改进 CI 的可观测性

我们非常感谢您提供的任何反馈,无论是分享您如何使用我们的产品、提出新功能建议、帮助我们发现和修复问题,还是任何其他想法。您的见解对我们而言弥足珍贵。

您可以通过以下方式联系我们:


基于Flink-Agents 0.2.1,开发者们构建了一个用于展示Flink-Agents能力的演示项目--Flink智能运维Agent,它可以自动分析 Flink 作业健康状况、提供诊断建议,并能利用可用工具尝试修复问题。

点击 LINK 查看 DEMO

相关实践学习
基于Hologres+Flink搭建GitHub实时数据大屏
通过使用Flink、Hologres构建实时数仓,并通过Hologres对接BI分析工具(以DataV为例),实现海量数据实时分析.
实时计算 Flink 实战课程
如何使用实时计算 Flink 搞定数据处理难题?实时计算 Flink 极客训练营产品、技术专家齐上阵,从开源 Flink功能介绍到实时计算 Flink 优势详解,现场实操,5天即可上手! 欢迎开通实时计算 Flink 版: https://cn.aliyun.com/product/bigdata/sc Flink Forward Asia 介绍: Flink Forward 是由 Apache 官方授权,Apache Flink Community China 支持的会议,通过参会不仅可以了解到 Flink 社区的最新动态和发展计划,还可以了解到国内外一线大厂围绕 Flink 生态的生产实践经验,是 Flink 开发者和使用者不可错过的盛会。 去年经过品牌升级后的 Flink Forward Asia 吸引了超过2000人线下参与,一举成为国内最大的 Apache 顶级项目会议。结合2020年的特殊情况,Flink Forward Asia 2020 将在12月26日以线上峰会的形式与大家见面。
相关文章
|
2月前
|
存储 消息中间件 关系型数据库
(二)走进阿里云实时计算Flink版-场景案例篇
阿里云实时计算Flink版产品负责人黄鹏程(马格)介绍:基于Apache Flink打造的企业级全托管实时计算平台,支持批流一体、湖仓融合、实时风控与AI推理等场景,助力满帮、车企等客户降本增效35%,SLA达99.9%。
642 3
(二)走进阿里云实时计算Flink版-场景案例篇
|
3月前
|
人工智能 Java API
Apache Flink Agents 0.2.0 发布公告
Apache Flink Agents 0.2.0发布!该预览版统一流处理与AI智能体,支持Java/Python双API、Exactly-Once一致性、多级记忆(感官/短期/长期)、持久化执行及跨语言资源调用,兼容Flink 1.20–2.2,助力构建高可靠、低延迟的事件驱动AI应用。
702 9
Apache Flink Agents 0.2.0 发布公告
|
2月前
|
存储 SQL Apache
(一)走进阿里云实时计算Flink版-产品能力篇
阿里云实时计算Flink版是企业级高性能实时大数据处理平台,由Flink创始团队打造。提供VVR+Flash双引擎,性能达开源Flink的3-4倍;支持动态扩缩容、SQL开发、CEP规则热更新、湖流一体(Fluss+Paimon)、大模型集成等能力,全面兼容开源生态。(239字)
609 3
(一)走进阿里云实时计算Flink版-产品能力篇
|
20天前
|
人工智能 运维 Apache
Flink Agents 0.3 Roadmap解读
Apache Flink Agents 是 Apache Flink 新晋子项目,专注构建事件驱动的流式 AI Agent。0.3 版本 roadmap 已公布:支持 Agent Skills 集成、Mem0 长期记忆、跨语言 Action/Events、Python 3.12、日志分级与可观测性增强等,目标打造生产级流式 Agent 框架。
254 2
|
7月前
|
人工智能 运维 监控
Flink 智能调优:从人工运维到自动化的实践之路
本文由阿里云Flink产品专家黄睿撰写,基于平台实践经验,深入解析流计算作业资源调优难题。针对人工调优效率低、业务波动影响大等挑战,介绍Flink自动调优架构设计,涵盖监控、定时、智能三种模式,并融合混合计费实现成本优化。展望未来AI化方向,推动运维智能化升级。
890 8
Flink 智能调优:从人工运维到自动化的实践之路
|
5月前
|
消息中间件 Java Kafka
在 OpenAI 打造流处理平台:超大规模实时计算的实践与思考
本文介绍OpenAI构建流处理平台的实践与挑战。面对Kafka高可用、Python生态兼容、云环境限制等问题,团队基于PyFlink打造跨区域流处理架构,集成Kafka HA组、自研代理与控制平面,支撑实时Embedding生成、特征计算等场景,并推动开源协作与平台自动化演进。
352 1
在 OpenAI 打造流处理平台:超大规模实时计算的实践与思考
|
1月前
|
人工智能 架构师 Apache
相约深圳,全球征集|Flink Forward Asia 2026 演讲议题征集正式启动
Flink Forward Asia 2026将于6月26–27日首次落地深圳,聚焦实时计算与AI深度融合。面向全球征集议题(截止5月29日),涵盖实时AI、AI Agent、湖流一体等前沿方向。免费报名开启,共探下一代实时计算范式!
244 4
相约深圳,全球征集|Flink Forward Asia 2026 演讲议题征集正式启动
|
1月前
|
数据采集 人工智能 自然语言处理
快速接入京东商品评论API,商品口碑监测与舆情风控
依托京东官方评价API,融合AI/NLP技术,构建“采集—分析—预警—决策”全链路口碑风控体系:实时监测情感倾向与负面问题,智能分级预警,支持归因分析与工单处置,助力品牌从被动响应转向主动运营。(239字)
|
8月前
|
人工智能 运维 Java
Flink Agents:基于Apache Flink的事件驱动AI智能体框架
本文基于Apache Flink PMC成员宋辛童在Community Over Code Asia 2025的演讲,深入解析Flink Agents项目的技术背景、架构设计与应用场景。该项目聚焦事件驱动型AI智能体,结合Flink的实时处理能力,推动AI在工业场景中的工程化落地,涵盖智能运维、直播分析等典型应用,展现其在AI发展第四层次——智能体AI中的重要意义。
2780 27
Flink Agents:基于Apache Flink的事件驱动AI智能体框架