Re: Cannot see all events in window apply() for big input

2016-11-10 Thread Sendoh
@Override public Watermark getCurrentWatermark() { return new Watermark(currentMaxTimestamp - maxTimeLag); } } Cheers, Sendoh -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Cannot-see-all-events-in-window-apply-for-big-input-tp99

Re: Cannot see all events in window apply() for big input

2016-11-08 Thread Till Rohrmann
t; So, using split(), or implementing an event type recognized > AssignerWithPeriodicWatermarks along with custom EventTimeTrigger would be > the solution? > > Best, > > Sendoh > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-arch

Re: Cannot see all events in window apply() for big input

2016-11-08 Thread Sendoh
split(), or implementing an event type recognized AssignerWithPeriodicWatermarks along with custom EventTimeTrigger would be the solution? Best, Sendoh -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Cannot-see-all-events-in-window-apply-for-big

Re: Cannot see all events in window apply() for big input

2016-11-08 Thread Till Rohrmann
the problem that watermark is gloabal rather than per event? > > Best, > > Sendoh > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Cannot-see-all- > events-in-window-apply-for-big-input-tp9945p9985.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >

Re: Cannot see all events in window apply() for big input

2016-11-08 Thread Sendoh
context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Cannot-see-all-events-in-window-apply-for-big-input-tp9945p9985.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Cannot see all events in window apply() for big input

2016-11-08 Thread Sendoh
-archive.2336050.n4.nabble.com/Cannot-see-all-events-in-window-apply-for-big-input-tp9945p9977.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Cannot see all events in window apply() for big input

2016-11-07 Thread Till Rohrmann
with > fewer events, and small topics always appear while big topics disappear. > > Best, > > Sendoh > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Cannot-see-all- > events-in-window-apply-for-big-inp

Re: Cannot see all events in window apply() for big input

2016-11-07 Thread Sendoh
-all-events-in-window-apply-for-big-input-tp9945p9950.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Cannot see all events in window apply() for big input

2016-11-07 Thread Till Rohrmann
} > }).writeAsText("test", > FileSystem.WriteMode.OVERWRITE).setParallelism(1); > > Is there any suggestion that we could try to fix the issue? > > Best, > > Sendoh > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Cannot-see-all- > events-in-window-apply-for-big-input-tp9945.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >

Cannot see all events in window apply() for big input

2016-11-07 Thread Sendoh
tion that we could try to fix the issue? Best, Sendoh -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Cannot-see-all-events-in-window-apply-for-big-input-tp9945.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.