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)