Hi, all I’m using Flink 1.6 and I’m goint to use RocksDBBackend as the checkpoint state backend. Before that, I need to make sure that the checkpoint can handle rescale. From the docs on Apache Flink https://ci.apache.org/projects/flink/flink-docs-release-1.6/ops/state/checkpoints.html, it says that the checkpoint do not support Flink’s rescaling, however, from the source code, the rescaling logic seems not to be related to the state backend if the substask’s states are restored from files successfully.
Could anyone explain this? Or tell me if I miss something? Best, Jiayi Liao
