Hi every one, We are building a flink job that keys on a dynamic value. Only a few events share the same key and events with new keys are consumed constantly.
For each key, there are some keyedState created the first time it is seen. And we clean up the keyedState if the key has not been seen for X minutes using a timer. My question is: If the key space is ever increasing? Does it result in an ever increasing checkpoint size even I clean up the keyedState? Thank you! Best, -Chen -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
