Apache Flink 1.10.2 发布

来源: OSCHINA
编辑: 局长
2020-08-26 07:28:23

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 之后,过时的类OptionsFactoryConfigurableOptionsFactory会被移除(不适用于 release-1.10 系列),请使用RocksDBOptionsFactoryConfigurableRocksDBOptionsFactory代替。如果任何类扩展了DefaultConfigurableOptionsFactory,也请重新编译应用程序代码。

默认情况下,在 FLINK-17800 之后,会为 RocksDB的ReadOptionssetTotalOrderSeek设置为 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

展开阅读全文
0 收藏
分享
0 评论
0 收藏
分享
返回顶部
顶部
返回顶部
顶部