Hi, Flink SQL 1.11 暂时还不兼容 Hive SQL 语法。这个功能的设计,最近才在社区中讨论,预计1.13中支持。可以关注下这个 design 的讨论:
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-152-Hive-Query-Syntax-Compatibility-td46928.html Best, Jark On Fri, 4 Dec 2020 at 11:45, 莫失莫忘 <[email protected]> wrote: > 最近尝试把一个生产 hive sql 任务,执行引擎切换成 flink 1.11.2 ,发现flink 11 对hive > SQL的支持有下列问题1、不支持 双引号 表示字符串 > 2、不支持 != 表示不等运算 > 3、不支持 类型隐式转换 > 4、不支持 split 函数 > 5、hive 不区分大小写,flink区分大小写 > 6、join右表 不支持是一个子查询(Calcite bug > https://issues.apache.org/jira/browse/CALCITE-2152) > 7、不支持 create table table1 as select * from pokes; 中的 as > > > > 暂时只测到这些问题。总体感觉flink11 对 hive SQL的语句支持还不够,无法把已有离线 hive sql 任务直接 切换到flink 引擎。
