[Blink]Cep SQL code generator bug

2019-03-19 文章 张洪涛
Hi 当CEP SQL Pattern中出现aggregate 操作 并且SQL code generator 没有split 情况下 code generator 会出现问题 TableConfigOptions.SQL_CODEGEN_LENGTH_MAX 设置为默认 即48 * 1024 SQL Example SELECT * FROM source MATCH_RECOGNIZE ( PARTITION BY userId ORDER BY proctime MEASURES ... SUM(e1.pri

Re: [PROGRESS UPDATE] [DISCUSS] Flink-Hive Integration and Catalogs

2019-03-19 文章 Shaoxuan Wang
Hi Bowen, Thanks for driving this. I am CCing this email/survey to user-zh@ flink.apache.org as well. I heard there are lots of interests on Flink-Hive from the field. One of the biggest requests the hive users are raised is "the support of out-of-date hive version". A large amount of users are sti

Re:[进度更新] [讨论] Flink 对 Hive 的兼容 和 Catalogs

2019-03-19 文章 董鹏
1、首先对flink纳入阿里麾下表示很兴奋,针对以下问题,根据我的一些经验,抛砖引玉: hive太重要了,稳定,夜间跑任务,可以满足。 - *各位在使用哪个版本的Hive?有计划升级Hive吗?*// cdh5版本 无计划升级 - *各位计划切换Hive引擎吗?有时间点吗?当Flink具备什么功能以后你才会考虑使用Flink读写Hive?*//尝试spark引擎跑夜间任务,不稳定。对于性能,不是特别追求,稳定了,就会尝试flink on hive - *各位使用Flink-Hive的动机是什么?只维护一套数据处理系统?使用Flink获取更好的性能?*//技术迭代,当然

[进度更新] [讨论] Flink 对 Hive 的兼容 和 Catalogs

2019-03-19 文章 Bowen Li
Flink中文频道的童鞋们,大家好, *我们想收集下大家对Flink兼容Hive方面的需求和意见*。 背景:去年12月的Flink Forward 中国站上,社区宣布了将推动Flink兼容Hive。今年2.21,在西雅图 Flink Meetup 上我们做了 “Integrating Flink with Hive” 的演讲,并进行了现场演示,收到很好的反响。现在已到三月中,我们已经在内部完成了构建Flink崭新的catalog架构,对Hive 元数据的兼容,和常见的通过Flink 读写 Hive数据的工作。我们已开始提交相关的PR和设计文档,将已开发的功能输送回社区。欢迎大家参与到项目