本文讲解如何在本地环境中使用 Apache Flink 将数据写入 Amazon S3。首先,下载 flink-s3-fs-hadoop 插件并放入 Flink 的 lib 目录。为访问国内 S3,在 conf 目录创建 core-site.xml 文件并设置 endpoint。然后,通过示例代码生成数据,配置 Java 包和应用属性。最后,运行程序验证数据是否成功写入 S3。
完成下面两步后,将自动完成登录并继续当前操作。