阿里云文档 2025-10-20

本文介绍如何在阿里云Flink中通过Iceberg REST与DLF Catalog对接,包括创建Catalog和执行查询的完整流程

本文为您介绍如何在阿里云实时计算Flink版上实现Flink SQL 以Iceberg REST与DLF Catalog对接。

文章 2025-10-16 来自:开发者社区

阿里云、Ververica、Confluent 与 LinkedIn 携手推进流式创新,共筑基于 Apache Flink Agents 的智能体 AI 未来

Apache Flink Agents:一项里程碑式合作,旨在构建可扩展、面向生产的事件驱动型流式智能体框架。 作者:宋辛童,Apache Flink PMC Member,阿里云高级技术专家 在 Flink Forward Barcelona 2025 大会上,我们宣布:阿里云、Ververica、Confluent 与 LinkedIn 四家数据流领域的领军企业正式携手,共同推进 Apa...

阿里云、Ververica、Confluent 与 LinkedIn 携手推进流式创新,共筑基于 Apache Flink Agents 的智能体 AI 未来
文章 2025-10-13 来自:开发者社区

零售数据湖的进化之路:滔搏从Lambda架构到阿里云Flink+Paimon统一架构的实战实践

01滔搏:中国最大运动零售运营商的数字化挑战 1.1 企业规模与影响力 图1 滔搏企业规模与影响力 滔搏作为中国颇具规模的运动零售运营商,于 2019 年在香港主板上市,2024/2025 财年实现年营业收入 270.1 亿元,净利润达 12.8 亿元。 滔搏拥有数千家...

零售数据湖的进化之路:滔搏从Lambda架构到阿里云Flink+Paimon统一架构的实战实践
阿里云文档 2025-09-18

Flink作业密码KMS加密解密

实时计算Flink版支持通过密钥管理服务(KMS)来对作业中的敏感配置(如数据库密码)进行加密与动态解密,保障密钥安全。本文以Flink JAR作业从RDS MySQL数据读取并写入实时计算开发控制台为例,详细介绍如何通过KMS对MySQL连接密码进行加密,并在Flink作业运行时动态解密使用。

阿里云文档 2025-07-24

阿里云身份管理

为确保您的阿里云账号及云资源使用安全,如非必要都应避免直接使用阿里云账号(即主账号)来访问实时计算 Flink 版。推荐的做法是使用RAM身份(即RAM用户、RAM角色)来访问。

阿里云文档 2025-04-22

阿里云Flink SQL如何基于SPL实现弱结构化分析

本文介绍Flink SQL基于SPL实现弱结构化分析的操作步骤。

阿里云文档 2025-04-22

阿里云Flink SQL如何基于SPL实现行过滤与列裁剪

本文介绍Flink SQL用SPL完成行过滤与列裁剪的操作步骤。

文章 2025-03-01 来自:开发者社区

阿里云基于 Flink CDC 的现代数据栈云上实践

摘要:本文来自阿里云高级开发工程师,Apache Flink Committer 阮航老师分享的阿里云基于 Flink CDC 的现代数据栈云上实践。主要分为以下四个内容: 基于 Flink CDC 的现代数据栈 CDC YAML 核心功能 CDC YAML 典型应用场景 Demo & 未来展望 ...

阿里云基于 Flink CDC 的现代数据栈云上实践
文章 2024-12-31 来自:开发者社区

探索阿里云 Flink 物化表:原理、优势与应用场景全解析

在大数据处理的广阔天地中,阿里云 Flink 作为一款强大的流批一体化开源平台,为众多企业提供了高效的数据处理能力。而其中的物化表(Materialized Table)功能更是犹如一把利剑,助力开发者攻克诸多复杂的数据难题。今天,就让我们一同深入探究阿里云 Flink 物化表的奥秘。 一、什么是阿里云 Flink 物化表 简单来说,物化表是 Flink 中一种特殊的数据存储结构...

问答 2024-08-07 来自:开发者社区

阿里云实时计算flink,cdc同步数据到kafka,cdas、ctas都失败,大家有遇到吗?

阿里云实时计算flink,cdc同步数据到kafka,cdas、ctas都失败,Message: code: 400, The config: [cleanup.policy] not in enums. format is invalid,大家有遇到吗?

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

产品推荐

阿里云实时计算Flink

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

+关注