阿里云文档 2026-02-02

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

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

阿里云文档 2026-01-12

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

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

阿里云文档 2025-12-19

Flink对接Fluss并以流批方式读取数据-实时计算 Flink版-阿里云

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

阿里云文档 2025-11-24

配置数据分区的自动与动态管理策略-实时计算 Flink版-阿里云

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

阿里云文档 2025-08-08

Flink最佳实践

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

问答 2025-02-17 来自:开发者社区

flink 读取oss-hdfs数据问题

Flink 尝试从 OSS 获取分区信息时,由于权限不足导致访问被拒绝。但是注意到这里的endpoint实际上是oss的endpoint,但是我的数据存储在oss-hdfs中,请问我该如何访问到oss-hdfs中的数据?已经在配置文件中设置fs.oss.jindo.endpoint: cn-beijing.oss-dls.aliyuncs.com

文章 2024-07-17 来自:开发者社区

实时计算 Flink版操作报错合集之Hadoop在将文件写入HDFS时,无法在所有指定的数据节点上进行复制,该如何解决

问题一:Flink CDC里flinkcdc写hudi的时候这个错误怎么弄? Flink CDC里flinkcdc写hudi的时候这个错误怎么弄? own Source) at org.apache.hadoop.hdfs.DF...

实时计算 Flink版操作报错合集之Hadoop在将文件写入HDFS时,无法在所有指定的数据节点上进行复制,该如何解决
问答 2023-01-16 来自:开发者社区

Flink往hdfs某个指定分区写数据,写一段时间为什么重命名失败?

最近flink落hdfs遇到一个问题,往hdfs某个指定分区写数据,写一段时间taskmanager发生自重启就会出现相同的文件,导致重命名失败,.part-a55f572a-4ccc-47bf-b8d5-9a2591907190-2-87.inprogress.dc5a6ac4-bbc3-4881-ac8e-89d45c6efde9

文章 2022-02-17 来自:开发者社区

Flink落HDFS数据按事件时间分区解决方案

0x1 摘要 Hive离线数仓中为了查询分析方便,几乎所有表都会划分分区,最为常见的是按天分区,Flink通过以下配置把数据写入HDFS, BucketingSink<Object> sink = new BucketingSink<>(path); //通过这样的方式来实现数据跨天分区 sink.setBucketer(new DateTimeBucketer<&a...

问答 2022-02-15 来自:开发者社区

flink用IDEA本地运行可以读取HDFS数据,然后把项目打包提交到flink集群,无法读取HDFS数据,出现以下错误,这是为何?

The program finished with the following exception: org.apache.flink.client.program.ProgramInvocationException: Job failed. (JobID: 74a2d820909fee963c4dea371b5c236c) at org.apache.flink.client.pr...

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

产品推荐

阿里云实时计算Flink

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

+关注