Re:eventTime语义一些设备的数据总是迟到被丢弃

[Ye Chen]

你好，
设备数据迟到多久？maxOutofOrderness设置一个合适的值，让迟到的数据到达窗口后再计算。



best regards







在 2021-08-03 15:15:37，"zwoi" <318666...@qq.com.INVALID> 写道：
>hi
>&nbsp; &nbsp; &nbsp; &nbsp;我的设备数据是这样的， 设备id id(设备的唯一标识), 时间戳 time，要处理的指标 value，
>&nbsp; &nbsp; &nbsp; &nbsp;在eventTime语义下watermark 生成方式为new 
>Watermark(Math.max(time, currentMaxTimestamp) -&nbsp;maxOutofOrderness)，
>&nbsp; &nbsp; &nbsp; &nbsp;我需要对设备数据 做 keyby(id) 
>分组后再计算，但总有几个设备数据迟到，导致这几个设备数据就一直计算不到，请问有什么解决办法吗？&nbsp;