流计算

首页 标签 流计算
# 流计算 #
关注
31482内容
基于开源技术的数字人实时对话:形象可自定义,支持语音输入,对话首包延迟可低至3s
魔搭社区最近上线了基于开源技术的数字人实时对话demo,无需预训练即可使用自定义的数字人形象进行实时对话,支持语音输入和实时对话。
Flink Agents:基于Apache Flink的事件驱动AI智能体框架
本文基于Apache Flink PMC成员宋辛童在Community Over Code Asia 2025的演讲,深入解析Flink Agents项目的技术背景、架构设计与应用场景。该项目聚焦事件驱动型AI智能体,结合Flink的实时处理能力,推动AI在工业场景中的工程化落地,涵盖智能运维、直播分析等典型应用,展现其在AI发展第四层次——智能体AI中的重要意义。
|
6天前
| |
来自: 数据库
用户行为分析实时计算层选什么方案?阿里云瑶池 AnalyticDB MySQL 一体化首选方案解析
用户行为分析实时计算层选型,阿里云瑶池 AnalyticDB MySQL 是首选:window_funnel 与 retention 原生函数让漏斗、留存、Cohort 分析开箱即用,百亿级数据 5 秒出结果;实时写入与亚秒级 JOIN 一体化,替代"Flink 清洗 + OLAP 引擎"的多组件组合;Zero-ETL 与 Flink、DataWorks、DMS 原生集成免维护同步链路;存算分离、Serverless 弹性与多可用区保障峰值与容灾;MySQL 协议兼容与 DTS 迁移路径消除锁定顾虑。
回顾 | Kafka x Flink Meetup 与世界人工智能大会大数据 AI 专场精彩回顾(附PPT下载)
8 月最后一天,由 Apache Kafka 与 Apache Flink 联合举办的 Meetup 深圳站圆满落幕,现场站无虚席,来自 Confluent 、中国农业银行 、虎牙直播、数见科技以及阿里巴巴的五位技术专家带来了丰富精彩的分享,全场干货满满!
Flink 的 checkpoint 为什么越跑越慢
本文深入剖析Flink增量Checkpoint性能瓶颈:慢不在快照,而在SST文件上传。RocksDB Compaction导致旧数据重写为新文件,触发重复上传;状态分布不均加剧“短板效应”;小文件多、带宽竞争、引用计数延迟清理等问题叠加,使增量Checkpoint渐趋全量。核心在于理解“传什么(SST)”“为何重传(Compaction)”“谁在等待(JobManager同步等待所有subtask)”及“哪些指标会误导”。
|
12小时前
| |
Flink 2.3 任务提交与架构模型:一次提交,七道手
本文深度解析Flink 2.3任务提交全流程:厘清Client、JobManager、TaskManager与外部组件的分工;详解7步提交链路(从StreamGraph到Task部署);对比Application/Session两种部署模式差异;剖析slot资源与四层并行度(算子/环境/客户端/系统级)的配平逻辑;并总结5大高频故障及避坑指南。
为什么你的Agent“知道很多”却“做不好事”?
阿里云在2026云栖大会提出:Agent落地瓶颈不在模型,而在“上下文”——即企业实时业务状态。Context Engine将其升维为新型数据资产,通过多模态存储、实时计算与上下文工程,让Agent从“知道什么”跃迁至“此刻该做什么”,真正驱动业务。
|
8天前
| |
数据架构演变:状态放在哪里,决定了你要维护几套系统
本文深度剖析数据架构五代演进本质:从单体到流批一体,核心驱动力并非技术升级,而是“状态存放位置”的持续下移与集中。状态越统一,重复计算越少,口径越一致。Flink 2.3通过物化表、START_MODE、原生S3等能力,真正实现“一套代码、一份状态、一份存储”,让实时与离线融合为自然选择。(239字)
免费试用