Hey all! I've created a short FLIP for rescalable non-partitioned state:
https://cwiki.apache.org/confluence/display/FLINK/FLIP-8%3A+Rescalable+Non-Partitioned+State This is related to an effort led by Till, Aljoscha, Stephan, and Stefan to allow rescaling of Flink jobs (see FLINK-3755, FLINK-4381, and https://docs.google.com/document/d/1G1OS1z3xEBOrYD4wSu-LuBCyPUWyFd9l3T9WyssQ63w/edit). FLIP-8 provides some explanation about why we need rescaling of non-partitioned state, how the APIs could look like and a high-level implementation idea. I think the main point for discussion should be the APIs. I would like to start working on an initial implementation next week. I would then extend the implementation/proposed changes part after figuring out more details/implications. Ufuk