Hi Flink community, I recently started working on dynamic scaling. As a first step we want to introduce state sharding which is a requirement for partitioned state to be re-distributable. The following design doc [1] explains the ideas behind it. Any feedback is highly appreciated :-)
[1] https://docs.google.com/document/d/1G1OS1z3xEBOrYD4wSu-LuBCyPUWyFd9l3T9WyssQ63w/edit?usp=sharing Cheers, Till
