Hi, everyone
I'd like to start a discussion about FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement [1]. CREATE TABLE AS SELECT(CTAS) statement has been support, but it's not atomic. It will create the table first before job running. If the job execution fails, or is cancelled, the table will not be dropped. So I want Flink to support atomic CTAS, where only the table is created when the Job succeeds. Improve user experience. Looking forward to your feedback. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-305%3A+Support+atomic+for+CREATE+TABLE+AS+SELECT%28CTAS%29+statement -- Best regards, Mang Zhang
