如题,我原先基于flink1.11和1.12貌似没这个问题。目前基于1.13出现这个问题。
问题描述如下:
我t1是kafka表,其中有个属性是event_time是row time属性,然后创建了view v1,通过select ........ ,
event_time from t1这样创建。  现在问题是这么创建之后,我基于v1查询报错说aggre.. window只能在time
attributes上定义。
不清楚是版本变化导致,还是我其他地方搞错了呢。

回复