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?

Reply via email to