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)

Reply via email to