amazon-web-services - Flink - AWS 上的外部检查点

Question

我计划在 AWS Kinesis Analytics for Java Applications 上使用 Flink 来执行有状态的流式聚合。

我想将检查点保存到持久存储中。我有哪些选择？

• 我可以通过 FsStateBackend 使用 S3 吗？

• RocksSB 呢？RocksDB 是 AWS Kineses Analytics for Java Applications 提供的吗？

谢谢！

Answer 1

关于 Kinesis Data Analytics for Java Applications 中的 Flink 检查点，本文展示了如何将检查点配置到 S3 存储桶。似乎 S3 是 AWS 推荐的持久存储。

您可以在Flink 的官方文档中看到FsStateBackend支持 S3 。

Answer 2

是的，您可以使用 FsStateBackend 将 Flink 的检查点存储在 Flink官方文档中推荐的 s3 存储桶中。

请找到我在 此处提供的详细工作答案。