Hi Luis, You may try ContinuousEventTimeTrigger <https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java> that continuously fire on given time interval instead of writing your own. Note that we recently fixed a bug for this trigger so I think only the trunk version is working.
Cheers, Manu On Thu, Nov 3, 2016 at 9:07 PM Kostas Kloudas <k.klou...@data-artisans.com> wrote: > Hi Luis, > > Can you try to comment the whole final windowing and see if this is works? > This includes the following lines: > > .windowAll(TumblingEventTimeWindows.of(Time.of(windowTime, timeUnit))) > > .trigger(new PartialWindowTrigger<>(partialWindowTime, timeUnit, > windowTime, timeUnit)) > .apply(creator.create(), windowAllFold, windowAllMerge); > > An additional note is that I would go for registering an event time timer > at the onEventTime > instead of checking the timestamp on the onElement(). This is because with > your implementation, > in order to fire a computation, you always have to wait for an element > outside the partial window interval to arrive. > > Cheers, > Kostas > > On Nov 3, 2016, at 11:31 AM, Luis Mariano Guerra <mari...@event-fabric.com> > wrote: > > .windowAll(TumblingEventTimeWindows.of(Time.of(windowTime, timeUnit))) > //.trigger(new PartialWindowTrigger<>(partialWindowTime, > timeUnit, windowTime, timeUnit)) > .apply(creator.create(), windowAllFold, windowAllMerge); > > >
