With HA enabled, Flink checks the configured ZooKeeper node for pre-existing jobs and checkpoints when starting.
What Stefan meant was that you can configure a different ZooKeeper node, which will start the cluster with a clean state. You can check the available config options here: https://ci.apache.org/projects/flink/flink-docs-release-1.2/setup/config.html#high-availability-ha On 8 December 2016 at 15:05:52, Al-Isawi Rami (rami.al-is...@comptel.com) wrote: > >
