Local recovery and high availability in Apache Flink