|
在执行 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 之后无论子句的位置任何,均可以正常运行。
|