开发者社区> 问答> 正文

生产hive sql 迁移flink 11 引擎,碰到的问题

最近尝试把一个生产 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 引擎。 *来自志愿者整理的flink邮件归档

展开
收起
小阿怪 2021-12-06 12:27:40 1179 0
1 条回答
写回答
取消 提交回答
  • 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 *来自志愿者整理的flink邮件归档

    2021-12-06 13:27:18
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Hive Bucketing in Apache Spark 立即下载
spark替代HIVE实现ETL作业 立即下载
2019大数据技术公开课第五季—Hive迁移到MaxCompute最佳实践 立即下载