通过修改S3AFileSystem,实现flink sink s3功能
舟率率 11/2/2023 flinks3
在flink-conf.yaml中如果没有配置s3相关参数配置,可以将s3参数内置到org.apache.hadoop.fs.s3a.S3AFileSystem,这样也能实现flink的sink功能.
S3AFileSystem所在依赖jar
org.apache.hadoop:hadoop-aws:x.x.x.jar
1
具体位置
魔法记事本 魔法记事本 在flink-conf.yaml中如果没有配置s3相关参数配置,可以将s3参数内置到org.apache.hadoop.fs.s3a.S3AFileSystem,这样也能实现flink的sink功能.
S3AFileSystem所在依赖jar
org.apache.hadoop:hadoop-aws:x.x.x.jar
具体位置