Hi Harshith, when you use Flink's Windowing API, the state of an event time window is cleared once the watermark passes the end time of the window (that's when the window fires) + the allowed lateness. So, as long as you don't configure additional allowed lateness (default=0), Flink will already behave as described by default.
Cheers, Konstantin On Thu, Feb 14, 2019 at 12:03 PM Kumar Bolar, Harshith <[email protected]> wrote: > Hi all, > > > > My application uses a keyed window that is keyed by a function of > timestamp. This means once that particular window has been fired and > processed, there is no use in keeping that key active because there is no > way that particular key will appear again. Because this use case involves > continuously expanding keys, I want to clear the state of a key as soon as > it is finished processing without having to configure timers. > > > > Is this something that can be achieved in the evictor method > or apply method after each keyed window is done processing? > > > > Thanks, > > Harshith > > > > > -- Konstantin Knauf | Solutions Architect +49 160 91394525 <https://www.ververica.com/> Follow us @VervericaData -- Join Flink Forward <https://flink-forward.org/> - The Apache Flink Conference Stream Processing | Event Driven | Real Time -- Data Artisans GmbH | Invalidenstrasse 115, 10115 Berlin, Germany -- Data Artisans GmbH Registered at Amtsgericht Charlottenburg: HRB 158244 B Managing Directors: Dr. Kostas Tzoumas, Dr. Stephan Ewen
