您现在的位置是:首页 > 文章详情

Flink Weekly | 每周社区动态更新 - 20200114

日期:2020-01-15点击:437

大家好,本文为 Flink Weekly 的第四期,由 Forward Xu 整理,主要内容包括:Flink 1.10 版本的发布测试,SQL catalog 读取关系数据库 schema 的相关建议以及 Flink Forward 旧金山的演讲邀请。

Flink 开发进展

[Release] 社区仍在测试和修复 Flink 1.10 的错误。您可以在发布燃尽板上进行操作。估计第一个 RC 版本很快就来了 。

https://issues.apache.org/jira/secure/RapidBoard.jspa?rapidView=349&projectKey=FLINK

[SQL] Bowen 建议在 Table API 中添加 JDBC 和 Postgres Catalog API。这样,Flink 可以自动创建关系数据库中对应的表。目前,用户需要手动在 Flink 上创建相应的表(包括 schema)。

https://cwiki.apache.org/confluence/display/FLINK/FLIP-92%3A+JDBC+catalog+and+Postgres+catalog

http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-92-JDBC-catalog-and-Postgres-catalog-tp36505.html

[configuration] Xintong 建议更改 Flink 内存配置的一些默认值(FLIP-49),并正在寻求反馈 。

http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Discuss-Tuning-FLIP-49-configuration-default-values-td36528.html

[datastream api] Congxian 建议统一从 statebackends 向 AppendingState 添加“空(null)” 值的处理。建议的原因是使所有 statebackends 拒绝“空(null)”值。

http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Make-AppendingState-add-refuse-to-add-null-element-tp36493.html

需要注意的一些缺陷

由于在发布测试,因此有很多活动,但是对于已经发布的版本,没有发现任何新的显著错误。

活动 / 博客文章 / 其他

Flink Forward 旧金山的演讲邀请即将结束,但是您仍然有机会将演讲提交给该演讲者(可能只有)北美的 Apache Flink 社区会议。如有疑问或如果您不确定是否要提交参与,请随时与 Konstantin 联系。

https://www.flink-forward.org/sf-2020

[即将举行的聚会] 1月18日,Preetdeep Kumar 将分享一些基本的 Flink DataStream processing API,然后进行动手演示。这将是在线活动。在会议链接中可以查看更多详细信息。

https://www.meetup.com/Hyderabad-Apache-Flink-Meetup-Group/events/267610014/

1月22日 Konstantin 的同事 Alexander Fedulov 将在马德里的 Apache Flink 聚会上使 Flink 进行欺诈检测。

https://www.meetup.com/Meetup-de-Apache-Flink-en-Madrid/events/267744681/

中文邮件问题答疑汇总

  • Flink 的 savepoint 为什么要设置成手动的?的问题解答:

http://apache-flink.147419.n8.nabble.com/flink-savepoint-checkpoint-td1229.html

  • Flink 消费 Kafka 没有数据问题的问题解答:

http://apache-flink.147419.n8.nabble.com/flink-Kafka-td1461.html

  • 关于 Flink 集群中调用 dubbo 服务的咨询:

http://apache-flink.147419.n8.nabble.com/flink-dubbo-td1467.html

  • 关于 Flink Plan Visualizer 什么时候会更新成1.9的样式的问题,tison 已经抄送给 Flink WebUI 重构的 Manager:

http://apache-flink.147419.n8.nabble.com/Flink-Plan-Visualizer-1-9-td1404.html#a1429

  • Flink 的每条数据既然都做了 checkpoint,做成全局分布式一致性快照,那还需要本地 state干啥呢?的问题解答:

http://apache-flink.147419.n8.nabble.com/checkpoint-state-td1122.html

  • 关于 Flink 遇到 valueState 自身的 NPE 的问题解答:

http://apache-flink.147419.n8.nabble.com/flink-valueState-NPE-td1447.html#a1459

  • 关于流处理任务失败该如何追回之前的数据的问题解答:

http://apache-flink.147419.n8.nabble.com/-td1016.html

  • 关于 Flink 是否可以通过代码设置 hadoop 的配置文件目录的问题解答:

http://apache-flink.147419.n8.nabble.com/flink-hadoop-td1445.html

  • 关于 Flink 算子状态查看的问题解答:

http://apache-flink.147419.n8.nabble.com/flink-td1441.html

  • 关于疑似 ParquetTableSource Filter Pushdown bug 的问题解答:

http://apache-flink.147419.n8.nabble.com/Re-ParquetTableSource-Filter-Pushdown-bug-tt1439.html

  • 关于 Flink 1.10 版本连接 hive 报错的问题解答:

http://apache-flink.147419.n8.nabble.com/flink1-10-hive-tt336.html

  • 关于 Flink 不同 StateBackend ProcessWindowFunction 的差别的问题解答:

http://apache-flink.147419.n8.nabble.com/FLINK-StateBackend-ProcessWindowFunction-tt1418.html#a1419

  • 关于 Jobgraph 生成的问题解答:

http://apache-flink.147419.n8.nabble.com/Re-jobgraph-tt1426.html

  • 关于注册 table 时 catalog 无法变更的问题解答:

http://apache-flink.147419.n8.nabble.com/table-catalog-tt1417.html#a1425

  • 关于 Flink sql confluent schema avro topic 注册成表的问题解答:

http://apache-flink.147419.n8.nabble.com/flink-sql-confluent-schema-avro-topic-tt1264.html

  • 使用 Flink SQL 时,碰到的【Window can only be defined over a time attribute column】的问题解答:

http://apache-flink.147419.n8.nabble.com/Flink-SQL-Window-can-only-be-defined-over-a-time-attribute-column-tt1407.html

  • 关于如何获取算子处理一条数据记录的时间的问题解答:

http://apache-flink.147419.n8.nabble.com/-tt1357.html#a1412

原文链接:https://yq.aliyun.com/articles/742778
关注公众号

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。

持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。

文章评论

共有0条评论来说两句吧...

文章二维码

扫描即可查看该文章

点击排行

推荐阅读

最新文章