When you modify a job by removing a stateful operator, then during a
restart when Flink tries to restore the state, it will complain that the
snapshot contains state that can not be restored.
The solution to this is to restart from the savepoint (or retained
checkpoint), specifying that you want t
Hi All,
I have multiple steam in flink job which contains different state such as
ValueState or MapState.
But I now I need to remove one stream having specific (UID,NAME) from the
JOB.
If I remove it I face issue while restoration stating operator does not
exists.
I was using BucketSink for sink
