Hi 使用withTimestampAssigner只是定义了生成watermark消息的策略,不会影响数据流。超出指定时间的数据是否处理,可以在定义window的时候使用allowedLateness定义最晚的late event,超出这个时间的窗口数据会直接丢弃
Best, Shammon FY On Sat, Mar 25, 2023 at 12:28 AM crazy <2463829...@qq.com.invalid> wrote: > 大佬好,如下程序,flink在生成watermark策略中,forBoundedOutOfOrderness > 这个乱序时长的指定会不会导致数据的丢失呢?比如有数据事件时间超过5ms,这条数据会进入到streamTS里吗? > > > SingleOutputStreamOperator<ClickEvent> streamTS = > mySource.assignTimestampsAndWatermarks( > > WatermarkStrategy.<ClickEvent>forBoundedOutOfOrderness(Duration.ofMillis(5)) > > .withTimestampAssigner( > new > SerializableTimestampAssigner<ClickEvent>() { > > @Override > > public long extractTimestamp(ClickEvent event, long > recordTimestamp) { > > return event.getDateTime(); > > } > > }) );