Hi,
Just to add to what Piotr already mentioned:
The community is working on adding support for this directly in Flink.
You can follow the efforts here:
https://issues.apache.org/jira/browse/FLINK-12047.
Cheers,
Gordon
On Tue, May 14, 2019 at 11:39 AM Piotr Nowojski wrote:
> Hi,
>
> Currently
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 r
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
