目录

1、项目构建

2、项目新增和修改

2.1 pom.xml 新增依赖

2.2 本地测试或者 flink on k8s 时，新增 S3FileSystemFactory.java

第一步：创建包=org.apache.flink.fs.s3hadoop

第二步：新增 java 类 S3FileSystemFactory

特别注意

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

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

第三步：修改 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>