Flink可以使用zookeeper来进行ha，而一般我们都会使用zookeeper的高级api架构curator来对zk进行通讯。在curator中引入了状态的概念，包括connected,reconnected,suspeneded,lost与read_only，其中suspended是个有意思的状态，当因为网络抖动、机器繁忙、zk集群短暂无响应，都会导致curator将状态置为suspended.Flink可以使用zookeeper来进行ha，而一般我们都会使用zookeeper的高级ap
阅读背景：
Zookeeper connection loss leads to Flink job restart
来源：互联网
分享到：
