@ guoliubin85
感谢回复，和你说的差不多，问题已经搞定。
在 2020-12-14 13:02:54，"guoliubi...@foxmail.com" <guoliubi...@foxmail.com> 写道：
>不好意思我没说清楚。
>我这边用的是这样的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)
>
>
>
>guoliubi...@foxmail.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 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，"guoliubi...@foxmail.com" <guoliubi...@foxmail.com> 写道：
>>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.
>>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的字段报错，如何解决。
