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中生成。感觉不太合理


麻烦了解的大佬抽空解答下,多谢!

Reply via email to