我使用的是在从docker-flink安装的ECS中运行的Flink。我已经通过flink-conf.yaml中的state.checkpoints.dir到S3启用了外部检查点到AWS S3。现在,根据Flink文档here,如果我们想在出现故障的情况下从检查点恢复,我们必须使用bin/flink run -s :checkpoint
我使用Apache读取kafka主题中的数据,并将其存储在服务器上的文件中。我使用FileSink存储文件,它按日期和时间顺序创建目录结构,但没有创建日志文件。/flink/testlogs/2021-12-08--07 我希望日志文件应该每15分钟写一次到一个新的日志文件。下面是密码。FileSink<Tuple6<String, String, St