阿里云文档 2025-09-16

Flink如何以EMR集群的方式可恢复性写入OSS-HDFS服务

可恢复性写入功能支持将数据以EXACTLY_ONCE语义写入存储介质。本文介绍Flink如何通过EMR集群的方式可恢复性写入OSS-HDFS服务。

阿里云文档 2025-09-16

开源版本Flink如何使用JindoSDK处理OSS HDFS服务的数据

开源Flink不支持流式写入OSS-HDFS服务,也不支持以EXACTLY_ONCE语义写入存储介质。当您希望开源Flink以EXACTLY_ONCE语义流式写入OSS-HDFS服务,需要结合JindoSDK。

阿里云文档 2025-04-01

实时计算Flink读写OSS或者OSS-HDFS

阿里云实时计算Flink支持通过连接器读写OSS以及OSS-HDFS数据。通过配置OSS或者OSS-HDFS连接器的输入属性,实时计算Flink会自动从指定的路径读取数据,并将其作为实时计算Flink的输入流,然后将计算结果按照指定格式写入到OSS或者OSS-HDFS的指定路径。

阿里云文档 2024-08-21

在挂载文件存储HDFS版的Hadoop集群上安装及使用ApacheFlink

本文介绍如何在挂载文件存储 HDFS 版的Hadoop集群上安装及使用Apache Flink。

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

flink1.18 api流失写入是加载表提示hdfs路径下表不存在

先在flink sql客户端中建表,语句如下:CREATE TABLE hive_catalog.default.sample (id INT COMMENT 'unique id',data STRING NOT NULL,PRIMARY KEY(id) NOT ENFORCED) with ('format-version'='2', 'write.upsert.enabled'='true....

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

Flink指定chepoint为hdfs路径,启动job报错。有人遇到此问题吗?

Flink指定chepoint为hdfs路径,启动job报错。有人遇到此问题吗?

问答 2023-04-11 来自:开发者社区

请问flink写hive,按小时分区,如果某个小时内一条数据都没有,那该小时对应的hdfs的目录路径

请问flink写hive,按小时分区,如果某个小时内一条数据都没有,那该小时对应的hdfs的目录路径会产生吗?

问答 2023-03-27 来自:开发者社区

我想问下flink任务在yarn 提交之后,想要获取对应jar的hdfs路径要怎么获取呢

我想问下flink任务在yarn 提交之后,想要获取对应jar的hdfs路径要怎么获取呢

问答 2023-01-27 来自:开发者社区

请问一下,flink checkpoint 的hdfs 路径,有台机器磁盘坏了了,导致flink任务

请问一下,flink checkpoint 的hdfs 路径,有台机器磁盘坏了了,导致flink任务失败,这种问题集群感知到了,yarn有告警提示,后面我通知运维手动隔离了那台机器,请问有自动隔离的办法吗?这样的话任务应该不会失败了

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

Flink Shaded Hadoop S3文件系统仍然需要hdfs-default和hdfs-site配置路径

我正在尝试使用Flink 1.6.0将S3配置为我的状态后端。 flink-conf.yamlstate.backend: filesystemstate.checkpoints.dir: s3://*/flink-checkpointsstate.savepoints.dir: s3://*/flink-savepoints s3.access-key: *s3.secret-key: *ht....

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

产品推荐

阿里云实时计算Flink

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

+关注