Okay, 和我理解的一样,这个时间上是 event time, 基于event time的 interval join 
需要定义watermark,目前hive表还不支持定义watermark,1.13应该会支持。



> 在 2021年2月1日,10:58,macdoor <macd...@gmail.com> 写道:
> 
> p1.time 是数据记录里的时间,也用这个时间做分区
> 
> 
> 
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/

回复