Martijn Visser created FLINK-41408:
--------------------------------------
Summary: 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: Table SQL / API
Reporter: Martijn Visser
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)
