Apache Flink 1.10.2 发布

Apache Flink 1.10.2 已发布，这是 Apache Flink 1.10 系列的第二个 Bugfix 版本，总共包含 73 个修复程序以及针对 Flink 1.10.1 的小改进。官方强烈建议所有用户升级到 Flink 1.10.2。

Maven

 <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>1.10.2</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_2.11</artifactId> <version>1.10.2</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-clients_2.11</artifactId> <version>1.10.2</version> </dependency>

注意事项：在 FLINK-18242 之后，过时的类OptionsFactory和ConfigurableOptionsFactory会被移除（不适用于 release-1.10 系列），请使用RocksDBOptionsFactory和ConfigurableRocksDBOptionsFactory代替。如果任何类扩展了DefaultConfigurableOptionsFactory，也请重新编译应用程序代码。

默认情况下，在 FLINK-17800 之后，会为 RocksDB的ReadOptions将setTotalOrderSeek设置为 true，以防止用户误用optimizeForPointLookup。同时支持ReadOptions通过RocksDBOptionsFactory进行自定义。如果观察到出现任何性能下降的情况，请重新设置setTotalOrderSeek为 false（根据测试通常不会发生）。

部分更新内容

Sub-task

• [FLINK-15836] - 修复当 Pod Watcher 异常关闭时，在 KubernetesResourceManager 中导致 fatal error 的问题
• [FLINK-16160] - 修复 Schema#proctime 和 Schema#rowtime 在 TableEnvironment#connect 代码路径中不起作用的问题

New Feature

• [FLINK-17844] - 在 bugfix 版本之间为 @PublicEvolving 激活 japicmp-maven-plugin 检查 (x.y.u -> x.y.v)

Improvement

• [FLINK-16217] - 改进引发任何未捕获的异常时，SQL Client 崩溃的情况
• [FLINK-16225] - 内存不足的元空间应在 TaskManager 中应作为 Fatal Error 处理
• [FLINK-17503] - 使内存配置日志记录更加用户友好
• [FLINK-17945] - 改进 Python CI 测试的错误报告
• [FLINK-18644] - 删除配置单元连接器的过时文档

详情查看 https://flink.apache.org/news/2020/08/25/release-1.10.2.html
下载地址 https://flink.apache.org/downloads.html