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"
<[email protected]>;
????????: 2020??10??7??(??????) ????2:25
??????: "??????"<[email protected]>;
????: "Shengkai
Fang"<[email protected]>;"user"<[email protected]>;
????: 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 ?????? <[email protected]> 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"
<[email protected]>;
????????: 2020??10??7??(??????) ????12:43
??????: "??????"<[email protected]>;
????: "user"<[email protected]>;
????: 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.
?????? <[email protected]> ??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