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/
