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
Hi Matthias, Thanks for the response. I guess the specific question would be, if I work with an existing savepoint and pass an empty DataStream to OperatorTransformation#bootstrapWith, will the new savepoint end up with an empty state for the modified operator, or will it maintain the existing sta

RE: Updating existing state with state processor API

2023-10-26 Thread Schwalbe Matthias
Good morning Alexis, Something like this we do all the time. Read and existing savepoint, copy some of the not to be changed operator states (keyed/non-keyed) over, and process/patch the remaining ones by transforming and bootstrapping to new state. I could spare more details for more specific