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