[ERROR] Could not execute SQL statement. 
Reason:org.apache.flink.table.api.TableException: Window aggregate can only be 
defined over a time attribute column, but TIMESTAMP(3) encountered.


SQL 如下:
create temporary view expose as

select  

mid

,time_local

,TO_TIMESTAMP(FROM_UNIXTIME(time_local / 1000, 'yyyy-MM-dd HH:mm:ss')) as log_ts

,proctime

from hive.temp.kafka_table

;
time_local 是bigint



select TUMBLE_START(log_ts, INTERVAL '1' MINUTE) as log_minute,count(1) pv

from expose

group by TUMBLE(log_ts, INTERVAL '1' MINUTE);


window agg的字段报错,如何解决。

回复