我计划在aws kinesis analytics for java应用程序上使用flink来执行有状态流聚合。我想将检查点保存到持久存储。我有什么选择？我可以使用fsstatebackend使用s3吗？rockssb呢？rocksdb是由aws kinesanalytics为java应用程序提供的现成的吗？谢谢！
uxhixvfz1#
关于java应用程序kinesis数据分析中的flink检查点，本文展示了如何将检查点配置到s3 bucket。似乎s3是aws推荐的持久存储。你看得出来 FsStateBackend 支持flink官方文档中的s3。
FsStateBackend
piv4azn72#
是的，您可以使用fsstatebackend将flink的检查点存储在s3 bucket中，这是flink官方文档中推荐的。请找到我在这里提供的详细的工作答案。
2条答案
按热度按时间uxhixvfz1#
关于java应用程序kinesis数据分析中的flink检查点，本文展示了如何将检查点配置到s3 bucket。似乎s3是aws推荐的持久存储。
你看得出来
FsStateBackend支持flink官方文档中的s3。piv4azn72#
是的，您可以使用fsstatebackend将flink的检查点存储在s3 bucket中，这是flink官方文档中推荐的。
请找到我在这里提供的详细的工作答案。