回复: Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered.

Sun, 13 Dec 2020 18:41:34 -0800 

TUMBLE第一个参数需要的就是bigint，你这边time_local 直接用就好，不用转另外TIMESTAMP



[email protected]
 
发件人： kandy.wang
发送时间： 2020-12-14 10:28
收件人： user-zh
主题： Window aggregate can only be defined over a time attribute column, but 
TIMESTAMP(3) encountered.
[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的字段报错，如何解决。

回复