Im running SQL along with a a custom trigger - so think about this scenario:
Select id, count(*) as count_events, atLeastOneIsTrue(booleanField) as shouldTrigger FROM my_table GROUP BY id transforming it to a retracted stream and then filtering by the shouldTrigger field, that works as expected. What happens is that if i get any event for the same id past the shouldTrigger=true condition, obviously it will trigger again (as atLeastOneIsTrue is still TRUE). I'm trying to prevent it, so similar to late events on window functions in [1] i want to ensure only a single trigger happens for any given id. I had a thought about whether this is related to withIdleStateRetentionTime but it doesn't seem right to me Any idea how i can achieve it? Thanks! Shahar [1] https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/stream/operators/windows.html#allowed-lateness -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
