[ 
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)

Reply via email to