[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
TUMBLE第一个参数需要的就是bigint,你这边time_local 直接用就好,不用转另外TIMESTAMP
guoliubi...@foxmail.com
发件人: 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
)'
'$TUMBLE(, , )'
在 2020-12-14 10:41:12,"guoliubi...@foxmail.com" 写道:
>TUMBLE第一个参数需要的就是bigint,你这边time_local 直接用就好,不用转另外TIMESTAMP
>
>
>
>guoliubi...@foxmail.com
>
>发件人: kandy.wang
>发送时间: 2020-12-14
.com
发件人: 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
e_local 直接用就好,不用转另外TIMESTAMP
>
>
>
>guoliubi...@foxmail.com
>
>发件人: kandy.wang
>发送时间: 2020-12-14 10:28
>收件人: user-zh
>主题: Window aggregate can only be defined over a time attribute column, but
>TIMESTAMP(3) encountere
以直接转成TIMESTAMP
>select someFunc(field)
>from `someTable`
>group by TUMBLE(eventTime, INTERVAL '1' SECOND)
>
>
>
>guoliubi...@foxmail.com
>
>发件人: kandy.wang
>发送时间: 2020-12-14 11:23
>收件人: user-zh
>主题: Re:回复: Window aggregate can only be defined over a t