Thanks for your replies,I have some understandings.
There are two cases. 1. if I use no keyed state in program,when it's killed,I can only resume from previous result 1. if I use keyed state in program,when it's killed,I can resume from previous result and previous variable temporary result. Am I right? Thanks for your guide. ------------------ ???????? ------------------ ??????: "Arvid Heise" <ar...@ververica.com>; ????????: 2020??10??7??(??????) ????2:25 ??????: "??????"<appleyu...@foxmail.com>; ????: "Shengkai Fang"<fskm...@gmail.com>;"user"<user@flink.apache.org>; ????: Re: why we need keyed state and operate state when we already have checkpoint? I think there is some misunderstanding here: a checkpoint IS (a snapshot of) the keyed state and operator state (among a few more things). [1] [1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/learn-flink/fault_tolerance.html#definitions On Wed, Oct 7, 2020 at 6:51 AM ?????? <appleyu...@foxmail.com> wrote: when the job is killed,state is also misssing. so why we need keyed state?Is keyed state useful when we try to resuming the killed job? ------------------ ???????? ------------------ ??????: "Shengkai Fang" <fskm...@gmail.com>; ????????: 2020??10??7??(??????) ????12:43 ??????: "??????"<appleyu...@foxmail.com>; ????: "user"<user@flink.apache.org>; ????: Re: why we need keyed state and operate state when we already have checkpoint? The checkpoint is a snapshot for the job and we can resume the job if the job is killed unexpectedly. The state is another thing to memorize the intermediate result of calculation. I don't think the checkpoint can replace state. ?????? <appleyu...@foxmail.com> ??2020??10??7?????? ????12:26?????? Could you tell me: why we need keyed state and operator state when we already have checkpoint? when a running jar crash,we can resume from the checkpoint automatically/manually. So why did we still need keyed state and operator state. Thanks -- Arvid Heise | Senior Java Developer Follow us @VervericaData -- Join Flink Forward - The Apache Flink Conference Stream Processing | Event Driven | Real Time -- Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany -- Ververica GmbH Registered at Amtsgericht Charlottenburg: HRB 158244 B Managing Directors: Timothy Alexander Steinert, Yip Park Tung Jason, Ji (Toni) Cheng