阿里云文档 2025-04-01

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

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

阿里云文档 2024-09-19

对象存储OSS连接器

本文为您介绍如何使用对象存储OSS连接器。

阿里云文档 2023-11-29

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

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

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

阿里云全托管flink-vvp平台hudi connector实践(基于emr集群oss-hdfs存储)

1. 上游数据准备上游数据以mysql为例作为hudi入湖的上游应用表,详细的建表、插入及更新语句如下droptable if exists `sunyf_db`.`flink_test_02_hudi`;createtable if not EXISTS `sunyf_db`.`flink_test_02_hudi`( id BIGINTnotnull PRIMARY KEY ,`name...

阿里云全托管flink-vvp平台hudi connector实践(基于emr集群oss-hdfs存储)
问答 2023-04-28 来自:开发者社区

问下阿里全托管flink下,怎么在代码中配置oss路径的hive-catalog?

问下阿里全托管flink下,怎么在代码中配置oss路径的hive-catalog?云下配置本地路径没问题,云上配置oss的hive-catalog 目录,直接报

阿里云文档 2022-12-28

如何在Flink集群中配置OSS来存储Checkpoint和Savepoint

本文通过示例为您介绍如何在E-MapReduce on ACK的Flink集群中配置OSS来存储Flink作业的Checkpoint和Savepoint。

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

产品推荐

阿里云实时计算Flink

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

+关注