[
https://issues.apache.org/jira/browse/FLINK-31533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852110#comment-17852110
]
Sergio Peña commented on FLINK-31533:
-------------------------------------
Hi [~luoyuxia] [~aitozi], I'd like to make some contribution to Flink to extend
the CTAS statement to allow a custom schema definition (columns, partition &
primary keys, watermarks, etc). I noticed this task and FLINK-31534 are meant
for a subset of those changes. Are you still considering in working on this at
some point? I see these comments were made a year ago, but I don't want to step
on others people's work if there's some progress or interest on it. Are you ok
if I take this task?
I'm going to write a FLIP with the proposal about the semantics for the schema
definition, which is similar to Mysql CTAS.
> CREATE TABLE AS SELECT should support to define partition
> ---------------------------------------------------------
>
> Key: FLINK-31533
> URL: https://issues.apache.org/jira/browse/FLINK-31533
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / API
> Reporter: luoyuxia
> Priority: Major
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)