Sergio Peña created FLINK-36861: ----------------------------------- Summary: CREATE TABLE AS with METADATA columns doesn't work Key: FLINK-36861 URL: https://issues.apache.org/jira/browse/FLINK-36861 Project: Flink Issue Type: Bug Reporter: Sergio Peña
When creating a table with CTAS with a metadata column in the CREATE part, if the source query already declares that, then the CTAS fails that it cannot override the metadata column: ``` CREATE TABLE payments ( payment_id STRING PRIMARY KEY NOT ENFORCED, payment_time TIMESTAMP(3) METADATA FROM 'timestamp' ) DISTRIBUTED BY HASH(payment_id) INTO 4 BUCKETS WITH ('connector' = 'kafka') AS SELECT payment_id, payment_time FROM source; ``` The error is: {{A column named 'payment_time' already exists in the source schema. Computed and metadata columns cannot overwrite regular columns.}} We should allow CTAS to write source columns to metadata columns (if metadata cols are not virtual). Only computed and virtual metadata columns should be read-only and not allowed in the query-to-sink. -- This message was sent by Atlassian Jira (v8.20.10#820010)