Are you starting the job from savepoint [1] when submitting it again? If not, it is considered as a new job and will not pick up the old state.
[1] https://ci.apache.org/projects/flink/flink-docs-stable/deployment/cli.html#starting-a-job-from-a-savepoint Regards, Roman On Fri, Mar 12, 2021 at 10:08 AM Maminspapin <un...@mail.ru> wrote: > > Hey, Roman > > I use every time the same key. > And I get the correct value in StateManager every time the processElement() > method executes. > > But then I stop the job and submit it again. > And first execution processElement() get me null in state store. The key > wasn't change. > > So, I'am in confuse > > Thanks, > Yuri L. > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
