[ 
https://issues.apache.org/jira/browse/FLINK-41408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Martijn Visser updated FLINK-41408:
-----------------------------------
    Component/s: Documentation

> Watermark on a computed column inherited through CREATE TABLE LIKE fails 
> validation
> -----------------------------------------------------------------------------------
>
>                 Key: FLINK-41408
>                 URL: https://issues.apache.org/jira/browse/FLINK-41408
>             Project: Flink
>          Issue Type: Bug
>          Components: Documentation, Table SQL / API
>            Reporter: Martijn Visser
>            Priority: Major
>
> CREATE TABLE Orders_in_file (
>     `user` BIGINT,
>     product STRING,
>     order_time_string STRING,
>     order_time AS TO_TIMESTAMP(order_time_string)
> ) WITH ('connector' = 'filesystem', 'path' = '/tmp/orders', 'format' = 
> 'json');
> CREATE TABLE Orders_in_kafka (
>     WATERMARK FOR order_time AS order_time - INTERVAL '5' SECOND
> ) WITH ('connector' = 'blackhole')
> LIKE Orders_in_file (EXCLUDING ALL INCLUDING GENERATED);
> The second statement fails with The rowtime attribute field 'order_time' is 
> not defined in the table schema ... Available fields: ['user', 'product', 
> 'order_time_string'], although the same LIKE without the watermark does 
> include order_time. MergeTableLikeUtil adds inherited physical and metadata 
> columns to the types it verifies the rowtime attribute against, but not 
> computed columns. FLINK-40153 fixed this for metadata columns. This is the 
> example on the CREATE TABLE page, so the docs show a statement that doesn't 
> work.



--
This message was sent by Atlassian Jira
(v10.3.26#10030026)

Reply via email to