If it indeed happened as you have described, I will be very interested in the expected behaviour.
Something I remembered before: the trigger condition meets just gives the runner/engine "permission" to fire, but runner/engine may not fire immediately. But I don't know if the engine/runner will guarantee to fire. -Rui On Mon, Jan 13, 2020 at 1:43 PM Aaron Dixon <atdi...@gmail.com> wrote: > I have the following trigger: > > .apply(Window > .configure() > .triggering(AfterWatermark > .pastEndOfWindow() > .withEarlyFirings(AfterPane > .elementCountAtLeast(1))) > .accumulatingFiredPanes() > .withAllowedLateness(Duration.ZERO) > > But in Dataflow I notice that I never get an ON_TIME firing for my window > -- I only see early firing for elements, and then nothing. > > My assumption is that AfterWatermark should give me a last, on-time pane > under this configuration when the watermark surpasses the window's end. > > Is my expectation correct? >
