Hi everyone,
I am using Apache Flink 1.20.4, and I have the following high-availability requirement:
I want to configure my Flink cluster so that if a job is running on one node (for example, Node 1) and that node suddenly fails, another node in the cluster automatically takes over the job from the latest available state. The new node should have access to all the required checkpoint/savepoint data so that the job can resume processing without data loss or manual intervention.
What is the recommended HA architecture and configuration to achieve this? Specifically:
• Which HA service should I use?
• Where should checkpoints/savepoints be stored?
• Which state backend is recommended?
I do not want to use Kubernetes or HDFS.
I have seen recommendations to use GlusterFS as shared storage for checkpoints and savepoints. Is GlusterFS a recommended approach for this setup, or is there a better alternative?
Any suggestions or best practices would be appreciated.