A checkpoint cannot be used for rescaling. You should take a savepoint, stop the application, and resume from the savepoint with a new parallelism.
https://ci.apache.org/projects/flink/flink-docs-release-1.6/ops/state/savepoints.html On Fri, Sep 14, 2018 at 1:50 AM 廖嘉逸 <bupt_...@163.com> wrote: > 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 > > > >
