Re: Can't create a savepoint with State Processor API

Yep, that works! Many thanks David, really appreciate it! -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Can't create a savepoint with State Processor API

You are very close. I got your example to work by switching from the MemoryStateBackend to the FsStateBackend, and adding bEnv.execute(); at the end of main(). I'm not sure why either of those might be necessary, but it doesn't seem to work without both changes. See https://gist.github.com/alpi

Can't create a savepoint with State Processor API

Hi everyone, I'm looking for a way to modify state inside an operator in Flink. I found State Processor API that allows to modify savepoints, which looks great. But I can't mak