I think there is a bug in Flink when running locally without a cluster. My code worked in a cluster, but failed when run locally.
My code does not save null values in Map State. > On Aug 9, 2020, at 11:27 PM, Tzu-Li Tai <tzuli...@gmail.com> wrote: > > Hi, > > For the NullPointerException, what seems to be happening is that you are > setting NULL values in your MapState, that is not allowed by the API. > > Otherwise, the code that you showed for bootstrapping state seems to be > fine. > >> I have yet to find a working example that shows how to do both >> (bootstrapping state and start a streaming application with that state) > > Not entirely sure what you mean here by "doing both". > The savepoint written using the State Processor API (what you are doing in > the bootstrap() method) is a savepoint that may be restored from as you > would with a typical Flink streaming job restore. > So, usually the bootstrapping part happens as a batch "offline" job, while > you keep your streaming job as a separate job. What are you trying to > achieve with having both written within the same job? > > Cheers, > Gordon > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
