You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "simenliuxing (Jira)" <ji...@apache.org> on 2022/01/19 09:46:00 UTC
[jira] [Updated] (FLINK-25700) flinksql Cascading Window TVF Aggregation exception
[ https://issues.apache.org/jira/browse/FLINK-25700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
simenliuxing updated FLINK-25700:
---------------------------------
Attachment: image-2022-01-19-17-45-57-124.png
> flinksql Cascading Window TVF Aggregation exception
> ----------------------------------------------------
>
> Key: FLINK-25700
> URL: https://issues.apache.org/jira/browse/FLINK-25700
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Affects Versions: 1.14.0
> Reporter: simenliuxing
> Priority: Major
> Attachments: image-2022-01-19-17-45-57-124.png
>
>
> flink version 1.14.0
> sql
>
> {code:java}
> CREATE TABLE order_test
> (
> order_price int,
> order_item varchar,
> ts as localtimestamp,
> WATERMARK FOR ts as ts - INTERVAL '5' SECOND
> ) WITH (
> 'connector' = 'datagen'
> );
> create view window_view2 as
> select window_start, window_end, window_time as rowtime, sum(order_price) partial_price
> from TABLE(
> TUMBLE(
> TABLE order_test, DESCRIPTOR(ts), INTERVAL '2' SECOND)
> )
> group by order_price, window_start, window_end, window_time;
> select window_start, window_end, sum(partial_price) total_price
> from TABLE(
> TUMBLE(
> TABLE window_view2, DESCRIPTOR(rowtime), INTERVAL '10' SECOND)
> )
> group by window_start, window_end;{code}
> exception
>
> {code:java}
> Caused by: org.apache.calcite.sql.validate.SqlValidatorException: Column 'window_start' is ambiguous
> at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
> at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
> at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
> at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
> at org.apache.calcite.runtime.Resources$ExInstWithCause.ex(Resources.java:467)
> at org.apache.calcite.runtime.Resources$ExInst.ex(Resources.java:560)
> ... 41 more{code}
>
>
> I think it's a bug
--
This message was sent by Atlassian Jira
(v8.20.1#820001)