存储配置
阿里云
登录后可跨设备保存划线和私人笔记登录
本页介绍如何让 Hudi Spark 作业将数据写入阿里云 OSS。
阿里云 OSS 配置
Hudi 与 OSS 兼容需要以下两项配置:
- 为 Hudi 添加阿里云 OSS 凭证
- 将所需的 Jar 包加入 classpath
阿里云 OSS 凭证
在 core-site.xml 中添加所需配置,Hudi 会从中读取这些配置。将 fs.defaultFS 替换为你的 OSS 存储桶名称,将 fs.oss.endpoint 替换为你的 OSS 端点,将 fs.oss.accessKeyId 替换为你的 OSS AccessKey,将 fs.oss.accessKeySecret 替换为你的 OSS AccessKey Secret。这样 Hudi 就应该能够对该存储桶进行读写操作。
<property>
<name>fs.defaultFS</name>
<value>oss://bucketname/</value>
</property>
<property>
<name>fs.oss.endpoint</name>
<value>oss-endpoint-address</value>
<description>Aliyun OSS endpoint to connect to.</description>
</property>
<property>
<name>fs.oss.accessKeyId</name>
<value>oss_key</value>
<description>Aliyun access key ID</description>
</property>
<property>
<name>fs.oss.accessKeySecret</name>
<value>oss-secret</value>
<description>Aliyun access key secret</description>
</property>
<property>
<name>fs.oss.impl</name>
<value>org.apache.hadoop.fs.aliyun.oss.AliyunOSSFileSystem</value>
</property>Aliyun OSS 库
需要添加到 pom.xml 中的 Aliyun Hadoop 库 jar 包。由于 hadoop-aliyun 依赖于 Hadoop 2.9.1+ 的版本,因此你需要使用 Hadoop 2.9.1 或更高版本。
<dependency>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-aliyun</artifactId>
<version>3.2.1</version>
</dependency>
<dependency>
<groupId>com.aliyun.oss</groupId>
<artifactId>aliyun-sdk-oss</artifactId>
<version>3.8.1</version>
</dependency>
<dependency>
<groupId>org.jdom</groupId>
<artifactId>jdom</artifactId>
<version>1.1</version>
</dependency>评论
登录后参与评论
正在加载评论…
KnowForge