flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From somnussuy <somnus...@163.com>
Subject rowtime/proctime
Date Sat, 27 Jul 2019 06:51:54 GMT
在执行 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 的影响是?




 
Mime
  • Unnamed multipart/mixed (inline, None, 0 bytes)
View raw message