Flink Weekly | 每周社区动态更新 - 2020/02/13

[OpenInx]

大家好，本文为 Flink Weekly
的第五期，由胡争(openinx)整理。由于中间过年有一周放假时间，加上之后的上班一周时间，所以这周将带来共两周的动态更新。

社区开发进展
==========

Apache Flink 1.9.2 版本于2020年1月30日正式发布。该版本实现了117个bug修复和优化，社区强烈推荐大家升级到Flink
1.9.2版本。
更多信息请参考：
[1] https://flink.apache.org/news/2020/01/30/release-1.9.2.html
[2]
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/ANNOUNCE-Apache-Flink-1-9-2-released-td37102.html

Gary发起了Flink 1.10
RC0版本的投票。但由于新引入module的license问题，导致本次投票失败。社区还发现了一些其他问题，这些将在下一个RC版本中修复。之后Gary继续发起两次RC的投票，按照社区的讨论来看，暂时没有新的Blocker
issue。
更多信息请参考：
[3]
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/VOTE-Release-1-10-0-release-candidate-1-td36985.html

Apache Flink社区已经一致通过把Docker Image发布流程集成到Apache Flink的版本发布流程。这意味着
https://github.com/docker-flink/docker-flink 将挪到Apache Flink项目下，并且Apache
Flink Docker Image将成为由Apache PMC成员投票认证的Apache官方发布项目。
更多信息请参考：
[4]
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/RESULT-VOTE-Integrate-Flink-Docker-image-publication-into-Flink-release-process-td37096.html

来自阿里巴巴的李钰受邀成为Apache Flink Committer，此前李钰是Apache HBase
PMC成员，之后在Flink社区主要负责State Backend及相关优化工作，此外他还担任了Apache Flink 1.10版本的Release
Manager，并为此做了大量工作。恭喜李钰！

Roman在FLIP-94中提议重新设计TwoPhaseCommitSinkFunction的抽象接口，这是他推动exactly-once JDBC
sink所必做的一部分工作。新的抽象设计将同时适用于exactly-once KafkaProducer和新的JDBC
sink，也便于引入像Cassandra Sink这样的WAL sinks。不过目前还没有收到任何反馈的。
[5]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-94%3A+Rework+2-phase+commit+abstractions

Gyula发起了一个集成Apache Atlas到Flink的讨论，这些集成的代码将维护在Apache Atlas项目中，但是Flink需要提供必要的
hooks，以及暴露必要的job metadata（尤其是source和sink相关的）。
[6]
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Discussion-Job-generation-submission-hooks-amp-Atlas-integration-td37298.html


Flink Python模块的相关进展：程鹤群编写Python ML Pipeline
API设计文档并发布到社区讨论；黄兴勃发起了在PyFlink中支持UDF的讨论；DianFu发起Scalar vectorized Python
UDF in PyFlink的讨论。

[7]
https://ponymail-vm.apache.org/_GUI_/thread.html/r81703d3bd9ce58b44197c48979e95df49ffd3df10ff50128b55dc4c7%40%3Cdev.flink.apache.org%3E
[8]
https://ponymail-vm.apache.org/_GUI_/thread.html/r6b6c3d39218ce70f37e7b2948ed06a674d01178365fd570fca6da900%40%3Cdev.flink.apache.org%3E
[9]
https://ponymail-vm.apache.org/_GUI_/thread.html/r0bec4dc6655028420abbee289f50e019f822eca115874b4133c0d7d8%40%3Cdev.flink.apache.org%3E

Apache Flink 1.10.0版本正式发布。该版本带来了大量的更新和优化，更多详情请参考：
https://flink.apache.org/news/2020/02/11/release-1.10.0.html

需要注意的一些缺陷
===============

FLINK-15918
在配置了jobmanager.execution.failover-strategy：region的情况下，uptime这个监控指标在重启时没有及时更新。该bug将在1.10版本中修复。
[10] https://issues.apache.org/jira/browse/FLINK-15918

活动博客文章及其他
===============

Seth Wiesman发布了一篇讨论Flink状态变更的文章，涉及state schema变更、State Processor API等话题。
[11]
https://flink.apache.org/news/2020/01/29/state-unlocked-interacting-with-state-in-apache-flink.html

Alexander Fedulov于2020/02/06日在R-Ladies会议上分享《Stateful Stream Processing with
Apache Flink》
[12] https://www.meetup.com/rladies-kyiv/events/267948988/

Kartik Khare在Apache Flink Blog发表了一篇关于如何做Flink Unit Test的文章。
[13]
https://flink.apache.org/news/2020/02/07/a-guide-for-unit-testing-in-apache-flink.html

社区组织公布第一批Flink Forward San
Francisco的Speaker，这些Speaker主要来自AWS、Cloudera、Google、Godaddy、Netflix等。
[14] https://www.flink-forward.org/sf-2020/speakers

Flink Forward London将在2020/02/19日召开，主题是“以图表形式监视和分析通讯和贸易事件”。
[15] https://www.meetup.com/Apache-Flink-London-Meetup/events/268400545/