@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
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
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
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.
>
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.
-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.
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
-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.
}
> }).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.
>
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.
10 matches
Mail list logo