Re: using CheckpointedFunction on a keyed state

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

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

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

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

Using CheckpointedFunction interface with Keyed state

Hi, I'm trying to understand the state functionality. Is there any case where using CheckpointedFunction with Keyed state makes any sense? Or the CheckpointedFunction is only to be used with operator state? Also, trying to understand the BufferinSink example here: https://ci.apache.org/projects