Flink is designed such that local state is backed up to a highly available system such as HDFS or S3. When a TaskManager fails state is recovered from there.
I suggest reading this: https://ci.apache.org/projects/flink/flink-docs-release-1.7/ops/state/state_backends.html On Fri, Jan 11, 2019 at 7:33 AM Siew Wai Yow <wai_...@hotmail.com> wrote: > Hello, > > May i know what happen to state stored in Flink Task Manager when this > Task manager crash. Say the state storage is rocksdb, would those data > transfer to other running Task Manager so that complete state data is ready > for data processing? > > Regards, > Yow >
