Just for the sake of experimenting and learning. Let's assume that we have a keyed process function using keyed state and we want to rewrite it using operator state. The question is, would that be possible to keep the exact same behaviour? For example, one could use operator union list state and then setup a timer to automatically remove the state not used within a given time...that would probably work but I'd rather prefer a way to know which elements of the union list state to use right after a recovery/restore, discarding the others, depending on the set of keys the current operator instance has been assigned. Is it possible to achieve this?
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
