If this would be the case, that would be a bug in Flink. As I said before, your implementation looked good to me. All state of window and trigger should be wiped if the trigger returns FIRE_AND_PURGE (or PURGE) and it's clean() method is correctly implemented.
I'll CC Aljoscha again for his opinion. We might need to file a JIRA for the issue. Thanks, Fabian 2017-09-19 11:32 GMT+02:00 gerardg <ger...@talaia.io>: > Thanks Fabian, I'll take a look to these improvements. > > I was wondering if the increasing state size could be due to that the UUID > used in the keyBy are randomly generated. Maybe even if I correctly delete > all the state related to a given key there is still some metadata related > to > the key wandering around. > > Gerard > > > > -- > Sent from: http://apache-flink-user-mailing-list-archive.2336050. > n4.nabble.com/ >
