RE: Updating existing state with state processor API

2023-10-31 Thread Schwalbe Matthias
, java.lang.String, org.apache.flink.runtime.state.StateBackend) From: Alexis Sarda-Espinosa Sent: Friday, October 27, 2023 4:29 PM To: Schwalbe Matthias Cc: user Subject: Re: Updating existing state with state processor API ⚠EXTERNAL MESSAGE – CAUTION: Think Before You Click ⚠ Hi Matthias

Re: Updating existing state with state processor API

2023-10-27 Thread Alexis Sarda-Espinosa
> > > > PS: I’m currently working on this ticket in order to get some glitches > removed: FLINK-26585 <https://issues.apache.org/jira/browse/FLINK-26585> > > > > > > *From:* Alexis Sarda-Espinosa > *Sent:* Thursday, October 26, 2023 4:01 PM > *To:* user &

RE: Updating existing state with state processor API

2023-10-26 Thread Schwalbe Matthias
isting state with state processor API Hello, The documentation of the state processor API has some examples to modify an existing savepoint by defining a StateBootstrapTransformation. In all cases, the entrypoint is OperatorTransformation#bootstrapWith, which expects a DataStream. If I pass an

Updating existing state with state processor API

2023-10-26 Thread Alexis Sarda-Espinosa
Hello, The documentation of the state processor API has some examples to modify an existing savepoint by defining a StateBootstrapTransformation. In all cases, the entrypoint is OperatorTransformation#bootstrapWith, which expects a DataStream. If I pass an empty DataStream to bootstrapWith and the