High availability in Apache Flink