目录

1、项目构建

2、项目新增和修改

2.1 pom.xml 新增依赖

flink%20on%20k8s%20%E6%97%B6%EF%BC%8C%E6%96%B0%E5%A2%9E%C2%A0S3FileSystemFactory.java-toc" style="margin-left:40px;">2.2 本地测试或者 flink on k8s 时，新增 S3FileSystemFactory.java

flink.fs.s3hadoop-toc" style="margin-left:80px;">第一步：创建包=org.apache.flink.fs.s3hadoop

第二步：新增 java 类 S3FileSystemFactory

特别注意

（1）本地测试时需要新增以下内容

（2）生产环境时，需要在 ${FLINK_HOME}/conf/config.yaml 中新增

flink%20sql-toc" style="margin-left:80px;">第三步：修改 flink sql 创建 s3_sink

3、运行查看结果

---

1、项目构建

参考前置项目先构建好项目：【Apache Paimon】-- 4 -- Flink 消费 kafka 数据，然后写入 paimon_paimon kafka-CSDN博客

2、项目新增和修改

2.1 pom.xml 新增依赖

       <dependency><groupId>org.apache.flink</groupId><artifactId>flink-s3-fs-hadoop</artifactId><version>1.19.1</version></dependency>