大家好，本文为 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