hi
       ?????????????????????? ????id id(??????????????), 
?????? time?????????????? value??
       ??eventTime??????watermark ??????????new 
Watermark(Math.max(time, currentMaxTimestamp) - maxOutofOrderness)??
       ???????????????? ?? keyby(id) 
?????????????????????????????????????????????????????????????????????????????????????????????? 

回复