如何解决Apache Flink-FsStateBackend-在任务管理器发生故障的情况下如何恢复状态，该状态将状态存储在其本地文件系统中
假设我们有2个工作经理（用于HA的ZooKeeper）和3个任务经理。我已经为检查点配置了FsstateBackend。我假设FsstateBackend在每个任务管理器中运行，从而在内存中保持状态。在检查点上，状态将保留在我们已配置的路径中（文件：/数据）。基本上，我已经配置了指向本地文件系统的路径。因此，每个任务管理器都有其自己的本地磁盘存储，这些存储了检查点数据。据我了解，少量元数据会在检查点发送给作业管理器。
- 如果任务管理器之一崩溃了怎么办？确保可以在任何可用的任务管理器中启动任务。由于任务管理器（崩溃的任务管理器）检查点数据不可用，因为它已关闭，因此如何恢复作业状态？检查点进程是否将状态信息发送到作业管理器？
- 任务管理器在检查点期间发送给作业管理器的元数据是什么？
- 我们使用的文件系统是否应该处于分布式状态？例如。 NFS，S3。如果我们使用系统本地存储进行检查点会发生什么情况。
谢谢
解决方法
您应始终使用分布式文件系统进行检查点。诸如HDFS，S3，GFS，NFS，Ceph等。此外，必须从所有参与的进程/节点（即所有任务管理器和作业管理器）访问所使用的存储路径。
否则，正如您所指出的，如果本地磁盘发生故障，检查点数据将丢失。
作业管理器具有有关检查点的完整知识，如果已配置HA，则此信息存储在已配置的HA存储提供程序中，以启用作业管理器故障转移。
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。