Apache Flink 1.10.2 发布-Linuxeden开源社区

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

转自 https://www.oschina.net/news/118162/apache-flink-1-10-2-released

相关推荐