rowtime/proctime

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

rowtime/proctime

somnussuy
在执行 SQL 的时候遇见如下情况:
 streamTableEnvironment.registerDataStream()注册的字段有一个是 over_time.rowtime
使用 sql:select tumble(over_time,interval '1' second),over_time from kafka_source group by over_time,tumble(over_time,interval '1' second)  会报错。ClassCastException 
如果 将 group by 后面的子句交换位置, group by tumble(over_time,interval '1' second) 能正常运行
如果 将 over_time 设置为 proctime,group by 之后无论子句的位置任何,均可以正常运行。
请问:
1. 两种 时间属性 对于该条 SQL 的影响是?