flink session cluster ha on k8s

[seuzxc]

hi,   is there any example about  ha  on k8s  for  flink  session  cluster.?   I've checked  the  docs on  flink.apache.org ,  seems no  info  about  this

[vino yang]

Hi 祥才,

You can refer to the reply of this old thread[1].

Best,

Vino

[1]: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Re-Re-how-to-setup-a-ha-flink-cluster-on-k8s-td31089.html

曾祥才 <[hidden email]> 于2019年11月25日周一 上午9:28写道：

hi,   is there any example about  ha  on k8s  for  flink  session  cluster.?   I've checked  the  docs on  flink.apache.org ,  seems no  info  about  this

[Yun Tang]

Currently, you still need zookeeper service to enable HA on k8s, and the configuration for this part is no different from YARN mode [1].

By the way, there also exists other solution to implement HA like etcd [2], but still in discussion.

 

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/jobmanager_high_availability.html#config-file-flink-confyaml

[2] https://issues.apache.org/jira/browse/FLINK-11105

 

Best

Yun Tang

 

From: 曾祥才 <[hidden email]>
Date: Monday, November 25, 2019 at 9:28 AM
To: User-Flink <[hidden email]>
Subject: flink session cluster ha on k8s

 

hi,   is there any example about  ha  on k8s  for  flink  session  cluster.?   I've checked  the  docs on  flink.apache.org ,  seems no  info  about  this