Thanks Taher. Are there any examples for this? In my scenario I would have data coming in and it might stop for sometime but I need the window to end after the duration.
Also, I believe in version 1.3 the event time will progress only if all partitions in a kafka topic pass the event time. Is that still the case? If there is data in only few partitions will the event time progress? Thanks On Mon, Jul 29, 2019 at 10:51 AM taher koitawala <taher...@gmail.com> wrote: > I believe the approach to this is wrong... For fixing windows we can write > our custom triggers to fire them... However what I'm not convinced with is > switching between event and processing time. > Write a custom triggers and fire the event time window if you > don't see any activity. That's the only way. > > On Mon, Jul 29, 2019, 11:07 PM Navneeth Krishnan <reachnavnee...@gmail.com> > wrote: > >> Hi All, >> >> Any suggestions? >> >> Thanks >> >> On Thu, Jul 25, 2019 at 11:45 PM Navneeth Krishnan < >> reachnavnee...@gmail.com> wrote: >> >>> Hi All, >>> >>> I'm working on a very short tumbling window for 1 second per key. What I >>> want to achieve is if the event time per key doesn't progress after a >>> second I want to evict the window, basically a combination of event time >>> and processing time. I'm currently achieving it by registering a processing >>> time timer but is there a way to emit some global punctuator which can be >>> used to evict all keys window data. >>> >>> The issue with registering processing time timer for every key is >>> causing too much JVM pressure. Any suggestions on how this could be >>> implemented? >>> >>> Thanks >>> >>
