Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered.
Locked
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的字段报错，如何解决。 |
|
|
TUMBLE第一个参数需要的就是bigint，你这边time_local 直接用就好，不用转另外TIMESTAMP
[hidden email] 发件人： 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的字段报错，如何解决。 |
Re:回复: Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered.
|
|
In reply to this post by kandy.wang
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，"[hidden email]" <[hidden email]> 写道： >TUMBLE第一个参数需要的就是bigint，你这边time_local 直接用就好，不用转另外TIMESTAMP > > > >[hidden email] > >发件人： 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的字段报错，如何解决。 |
|
|
不好意思我没说清楚。
我这边用的是这样的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) [hidden email] 发件人： 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，"[hidden email]" <[hidden email]> 写道： >TUMBLE第一个参数需要的就是bigint，你这边time_local 直接用就好，不用转另外TIMESTAMP > > > >[hidden email] > >发件人： 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的字段报错，如何解决。 |
Re:回复: Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered.
|
|
In reply to this post by kandy.wang
Hi，
Window agg 使用可以参考[1]，其中 first argument 可以是 Process time 或者 Eventime。 [1] https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/sql/queries.html#group-windows Best, Hailong 在 2020-12-14 09:41:12，"[hidden email]" <[hidden email]> 写道： >TUMBLE第一个参数需要的就是bigint，你这边time_local 直接用就好，不用转另外TIMESTAMP > > > >[hidden email] > >发件人： 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的字段报错，如何解决。 |
Re:回复: Re: Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered.
|
|
In reply to this post by kandy.wang
@ guoliubin85 感谢回复，和你说的差不多，问题已经搞定。 在 2020-12-14 13:02:54，"[hidden email]" <[hidden email]> 写道： >不好意思我没说清楚。 >我这边用的是这样的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) > > > >[hidden email] > >发件人： 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，"[hidden email]" <[hidden email]> 写道： >>TUMBLE第一个参数需要的就是bigint，你这边time_local 直接用就好，不用转另外TIMESTAMP >> >> >> >>[hidden email] >> >>发件人： 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的字段报错，如何解决。 |
«
Return to Apache Flink 中文用户邮件列表
|
1 view|%1 views
| Free forum by Nabble | Edit this page |