Thanks for your answer, but I still have some questions. Could you tell me why the checkpoint cannot be used for rescaling? From my perspective, the difference between checkpoint and savepoint is nullable externalSavepointLocation. And from this doc:https://flink.apache.org/features/2017/07/04/flink-rescalable-state.html, it talked about rescaling based on the checkpointing. Do I confuse these two things?
Original Message Sender:杨力bill.le...@gmail.com Recipient:廖嘉逸bupt_...@163.com Cc:useru...@flink.apache.org Date:Friday, Sep 14, 2018 02:03 Subject:Re: Can rocksDBBackend handle rescaling? 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 Flinkhttps://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
