Re: using CheckpointedFunction on a keyed state

2023-09-10 Thread liu ron
and snapshotState() are mainly used to initialize >> operator state, not keyed state … refer to the relevant documentation. >> >> >> >> >> >> Thias >> >> >> >> >> >> *From:* Krzysztof Chmielewski >>

Re: using CheckpointedFunction on a keyed state

2023-09-08 Thread Krzysztof Chmielewski
ion. > > > > > > Thias > > > > > > *From:* Krzysztof Chmielewski > *Sent:* Donnerstag, 7. September 2023 09:59 > *To:* user > *Subject:* using CheckpointedFunction on a keyed state > > > > ⚠*EXTERNAL MESSAGE – **CAUTION: Think Before You Click *⚠ &

RE: using CheckpointedFunction on a keyed state

2023-09-07 Thread Schwalbe Matthias
Subject: using CheckpointedFunction on a keyed state ⚠EXTERNAL MESSAGE – CAUTION: Think Before You Click ⚠ Hi, I have a toy Flink job [1] where I have a KeyedProcessFunction implementation [2] that also implements the CheckpointedFunction. My stream definition has .keyBy(...) call as you can see

using CheckpointedFunction on a keyed state

2023-09-07 Thread Krzysztof Chmielewski
Hi, I have a toy Flink job [1] where I have a KeyedProcessFunction implementation [2] that also implements the CheckpointedFunction. My stream definition has .keyBy(...) call as you can see in [1]. However when I'm trying to run this toy job I'm getting an exception from CheckpointedFunction::init