Hi guys, We want to have an accurate idea of how users actually use high-availability services in Flink, especially how you customize high-availability services by HighAvailabilityServicesFactory.
Basically there are standalone impl., zookeeper impl., embedded impl. used in MiniCluster, YARN impl. not yet implemented, and a gate to customized implementations. Generally I think standalone impl. and zookeeper impl. are the most widely used implementations. The embedded impl. is used without awareness when users run a MiniCluster. Besides that, it is helpful to know how you guys customize high-availability services using HighAvailabilityServicesFactory interface for the ongoing FLINK-10333[1] which would evolve high-availability services in Flink. As well as whether there is any user take interest in the not yet implemented YARN impl.. Any user case should be helpful. I really appreciate your time and your insight. Best, tison. [1] https://issues.apache.org/jira/browse/FLINK-10333
