1. create table语句不支持create talbe if not exists: 不支持if not exists语法在实际使用时特别麻烦,每次重新执行SQL都需要先删除上次执行创建的table。 Q1: CREATE TABLE IF NOT EXITS语法个人理解实现并不特别麻烦,社区为什么还没实现? 2. flink1.11创建kafka sink表时不再支持update-mode属性: 创建kafka sink表时报不支持udpate-mode属性的语法检验错误。但查看flink1.11源码中仍存在多个测试类在使用update-mode属性。 Q2:从flink1.11开始,kafka数据源的建表语句是否明确不再支持update-mode?(官网示例中已删除,但源码测试类中仍存在) 3. update-mode属性校验失败,任务推出,但该表却已经在catalog中生成 Q3:建表语句的属性校验失败,任务异常退出,但该表却已经在catalog中生成。感觉不太合理
麻烦了解的大佬抽空解答下,多谢!