内容简介:本周社区摘要,包括Flink 1.8.1和Flink 1.9.0的更新,这是我们开发过程中的另一个主题和一些与API相关的线程。我仍然不时包含较旧的线程。enjoy!与往常一样,请随时添加其他更新和新闻![1] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-META-FLIP-Sticking-or-not-to-a-strict-FLIP-voting-process-td29978.html [2] http
本周社区摘要,包括Flink 1.8.1和Flink 1.9.0的更新,这是我们开发过程中的另一个主题和一些与API相关的线程。我仍然不时包含较旧的线程。enjoy!
与往常一样,请随时添加其他更新和新闻!
Flink Development
-
[development-process] Aljoscha开始讨论我们的FLIP流程。特别是,他指出我们目前没有遵循我们自己的规则,这些规则要求“lazy majority”(3绑定+ 1)接受FLIP。实际上,大多数FLIP在没有投票或“lazy approval”的情况下被“接受”。通常会有很多积极的反馈来强制执行“lazy majority”。此外,还提出了哪些更改需要FLIP,FLIP可以有多大以及我们是否可以使用投票流程将FLIP范围扩展到版本中的问题。[1]
-
[releases] Jincheng已准备好 Flink 1.8.1 的第一个候选版本进行投票。为推动这一进程需要进行额外的测试和投票。
-
[releases] Flink 1.9.0 的功能冻结已推迟一周(7月5日),以完成基于Blink的Table API Runner和细粒度恢复的工作。
-
[datastream-api] Vino Yang提出(FLIP-44)通过引入“本地键控状态”的新概念来支持Flink中的本地聚合。似乎需要进一步讨论。具体来说,社群尚未就FLIP的主要目的达成一致(本地聚合可以减轻数据偏差对引入本地键控状态的影响,也可以用于前者),因此也存在关于API的开放性问题 和实施。[4]
-
[table-api] 当一个
flatAggregate
函数创建一个DynamicTable时,它目前无法将它连接到UpsertStreamTableSink
,因为在'flatAggregate`之后它不清楚,用于upsert的唯一键。Jincheng已经开始讨论以缓解这种情况,并提供了一个设计文档,列出了在唯一键上添加缺失信息的不同选项。[5] -
[client-api] 几周前,Jeff开始就改进Flink的客户端API和更好的程序化作业和集群控制进行对话。这将使下游项目(例如Zeppelin,Beam)更容易与Flink集成。该计划在全球范围内受到广泛好评,但由于其复杂性和涉及的许多公共API,需要进行一些额外的前期设计讨论。
[1] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-META-FLIP-Sticking-or-not-to-a-strict-FLIP-voting-process-td29978.html [2] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/VOTE-Release-1-8-1-release-candidate-1-td29929.html [3] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/ANNOUNCE-Feature-freeze-for-Apache-Flink-1-9-0-release-td29751.html [4] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Support-Local-Aggregation-in-Flink-td29307.html [5] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Support-Upsert-mode-for-Streaming-Non-window-FlatAggregate-tp29975.html [6] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Flink-client-api-enhancement-for-downstream-project-td25844.html
Notable Bugs
没有什么能引起我的注意。到目前为止,仅关注已发布的版本。
值得一提的是,FLINK-11662(在每周社区更新2019/24 [7]中有所报道)已得到解决。
[7] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/ANNOUNCE-Weekly-Community-Update-2019-24-tp29630.html
Events, Blog Posts, Misc
-
Jincheng现在是Apache Flink PMC的一部分。恭喜![8]
-
下周会有几场聚会
-
2019/07/01:巴黎 Apache Beam Meetup以及我自己的Flink 分享(Ververica)[9]
-
2019/07/05:Apache Flink Meetup 慕尼黑与 Steffen Hausmann(AWS)和Michel David(Ryte)[10]
[8] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/ANNOUNCE-Jincheng-Sun-is-now-part-of-the-Flink-PMC-td29868i20.html#a29966 [9] https://www.meetup.com/Paris-Apache-Beam-Meetup/events/261775884/ [10] https://www.meetup.com/Apache-Flink-Meetup-Munich/events/261282757/
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
猜你喜欢:本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
写给大忙人看的Java SE 8
【美】Cay S. Horstmann(凯.S.霍斯曼) 编 / 张若飞 / 电子工业出版社 / 2014-11 / 59.00元
《写给大忙人看的Java SE 8》向Java开发人员言简意赅地介绍了Java 8 的许多新特性(以及Java 7 中许多未被关注的特性),《写给大忙人看的Java SE 8》延续了《快学Scala》“不废话”的风格。 《写给大忙人看的Java SE 8》共分为9章。第1章讲述了lambda表达式的全部语法;第2章给出了流的完整概述;第3章给出了使用lambda表达式设计库的有效技巧;第4章......一起来看看 《写给大忙人看的Java SE 8》 这本书的介绍吧!