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

Sun, 13 Dec 2020 21:03:23 -0800 

不好意思我没说清楚。
我这边用的是这样的SQL可以运作，你可以参考下。
CREATE TABLE `someTable` (
  eventTime TIMESTAMP(3),
  WATERMARK FOR eventTime AS eventTime
)
eventTime是java的Long类型，包含毫秒，SQL里可以直接转成TIMESTAMP
select someFunc(field)
from `someTable`
group by TUMBLE(eventTime, INTERVAL '1' SECOND)



[email protected]
 
发件人： kandy.wang
发送时间： 2020-12-14 11:23
收件人： user-zh
主题： Re:回复: Window aggregate can only be defined over a time attribute column, 
but TIMESTAMP(3) encountered.
hi guoliubin85：
一样的报错：
 
Flink SQL> select mid,code,floor_id,TUMBLE_START(time_local/1000, INTERVAL '1' 
MINUTE) as log_minute,count(1) pv
 
> from lightart_expose
 
> where code is not null and floor_id is not null
 
> group by mid,code,floor_id,TUMBLE(time_local/1000, INTERVAL '1' 
> MINUTE);[ERROR] Could not execute SQL statement. Reason:
 
org.apache.calcite.sql.validate.SqlValidatorException: Cannot apply '$TUMBLE' 
to arguments of type '$TUMBLE(<BIGINT>, <INTERVAL MINUTE>)'. Supported form(s): 
'$TUMBLE(<DATETIME>, <DATETIME_INTERVAL>)'
 
'$TUMBLE(<DATETIME>, <DATETIME_INTERVAL>, <TIME>)'
 
 
 
> group by mid,code,floor_id,TUMBLE(time_local/1000, INTERVAL '1' 
> MINUTE);[ERROR] Could not execute SQL statement. Reason:
org.apache.calcite.sql.validate.SqlValidatorException: Cannot apply '$TUMBLE' 
to arguments of type '$TUMBLE(<BIGINT>, <INTERVAL MINUTE>)'. Supported form(s): 
'$TUMBLE(<DATETIME>, <DATETIME_INTERVAL>)'
'$TUMBLE(<DATETIME>, <DATETIME_INTERVAL>, <TIME>)'
 
在 2020-12-14 10:41:12，"[email protected]" <[email protected]> 写道：
>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的字段报错，如何解决。

回复