阿里云文档 2026-06-07

数据分区-实时计算 Flink版-阿里云

本文将介绍分区表的三种管理策略。

阿里云文档 2026-04-17

流批读取查询与消费模式-实时计算 Flink版-阿里云

本文将为您介绍读取Fluss数据的流批方式。

阿里云文档 2026-02-02

多种实时数据聚合方案对比选择-实时计算 Flink版-阿里云

本文将为您介绍三种实时聚合的方案,也是技术递进的过程,适用于不同的场景。

阿里云文档 2026-01-12

数据分桶策略类型与配置详解-实时计算 Flink版-阿里云

本文将介绍Fluss表的分桶策略。

文章 2025-08-14 来自:开发者社区

Flink 2.1 SQL:解锁实时数据与AI集成,实现可扩展流处理

Flink 2.1 SQL 的关键进展 本篇将探讨三个部分: Data + AI:在 Flink SQL 中连接实时数据处理与AI能力 首先,将介绍 Flink SQL 2.1 如何连接实时数据处理与AI能力。您将看到我们如何增强对 AI 函数的支持,从模型注册到通过 ML_PREDICT 与 SQL 的无缝集成,支持大模型文本生成和RAG工作流等任务。 ...

Flink 2.1 SQL:解锁实时数据与AI集成,实现可扩展流处理
文章 2025-08-08 来自:开发者社区

Flink 2.1 SQL:解锁实时数据与AI集成,实现可扩展流处理

本文整理自阿里云的高级技术专家、Apache Flink PMC 成员李麟老师在 Flink Forward Asia 2025 新加坡站 —— 实时 AI 专场中的分享。将带来关于 Flink 2.1 版本中 SQL 在实时数据处理和 AI 方面进展的话题。 Flink 2.1 SQL 的关键进展 本篇将探讨三个部分: Data + AI:在 Flink SQL 中连接实时数据处理与AI能力.....

Flink 2.1 SQL:解锁实时数据与AI集成,实现可扩展流处理
阿里云文档 2025-08-08

Flink最佳实践

本文主要介绍实时计算 Flink 版在读取数据和写入数据的最佳实践,确保可以高效地读写云原生数据仓库 AnalyticDB MySQL 版的数据。

文章 2025-08-07 来自:开发者社区

从 Flink 到 Doris 的实时数据写入实践 —— 基于 Flink CDC 构建更实时高效的数据集成链路

Flink-Doris-Connector 作为 Apache Flink 与 Doris 之间的桥梁,打通了实时数据同步、维表关联与高效写入的关键链路。本文将深入解析 Flink-Doris-Connector 三大典型场景中的设计与实现,并结合 Flink CDC 详细介绍了整库同步的解决方案,助力构建更加高效、稳定的实时数据处理体系。 一、Apache Doris 简介 Apache Do....

从 Flink 到 Doris 的实时数据写入实践 —— 基于 Flink CDC 构建更实时高效的数据集成链路
文章 2025-07-04 来自:开发者社区

京东零售基于Flink的推荐系统智能数据体系

京东推荐系统的数据体系极其复杂,从召回、模型到策略和效果评估,每个环节都需要强大的海量数据处理能力支撑。然而,在实际运行中,整个数据链路面临着诸多挑战:如实时与离线数据的埋点口径不一致、数仓模型存在偏差、计算口径不统一等问题,都会直接影响推荐效果的优化。更棘手的是,由于数据来源多样、体量庞大,整个推荐系统的数据质量控制和校验机制往往难以得到有效保障。 01推荐系统架构 ...

京东零售基于Flink的推荐系统智能数据体系
问答 2025-06-19 来自:开发者社区

Flink消费SLS数据,出现读取数据缺失

使用官方提供的代码实现的Flink消费SLS数据出现的问题是出现了漏数据的情况,SLS有3w条数据,但是实际只读到了2w8千条数据,我修改每次读取的数量之后能够读取到的数量会变少

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注