Hi Navneeth, Answering your three questions separately:
1. Yes. Your MapState will be backed by RocksDB, so when removing an entry from the map state, the state will be removed from the local RocksDB as well. 2. If state classes are not POJOs, they will be serialized by Kryo, unless a custom serializer is specifically specified otherwise. You can take a look at this document on how to do that [1]. 3. I might need to know more information to be able to suggest properly for this one. How are you using the "huge state values"? From what you described, it seems like you only need it on one of the parallel instances, so I'm a bit curious on what they are actually used for. Are they needed when processing your records? Cheers, Gordon [1] https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/stream/state.html#custom-serialization-for-managed-state -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
