Hi, Currently there is no native Flink support for modifying the state in a such manner. However there is an on-going effort [1] and a third party project [2] to address exactly this. Both allows you you to read savepoint, modify it and write back the new modified savepoint from which you can restore.
[1] https://github.com/sjwiesman/flink/commits/savepoint-connector <https://github.com/sjwiesman/flink/commits/savepoint-connector> [2] https://github.com/king/bravo <https://github.com/king/bravo> You can take a look at them. Piotrek > On 14 May 2019, at 09:55, bastien dine <[email protected]> wrote: > > Hello, > > I would like to have some advices about splitting an operator with a state > into multiple operators. > The new operators would have state containing pieces of information of the > initial state > We will "split" the state > > For exemple, I have operator (process) with uid A, with a state containing > field1, field2 > I would like to split it into two operator B & C with, respectively, state > field1 and state field2 > > How can I split my state upon multiple operators ? > > Best Regards, > Bastien > > ------------------ > > Bastien DINE > Data Architect / Software Engineer / Sysadmin > bastiendine.io <http://bastiendine.io/>
