车驰夜幕|Apache Flink 1.10.2发布,官方强烈建议升级

Apache Flink 1.10.2 已发布 , 这是 Apache Flink 1.10 系列的第二个 Bugfix 版本 , 总共包含 73 个修复程序以及针对 Flink 1.10.1 的小改进 。 官方强烈建议所有用户升级到 Flink 1.10.2 。
车驰夜幕|Apache Flink 1.10.2发布,官方强烈建议升级Maven
org.apache.flinkflink-java1.10.2org.apache.flinkflink-streaming-java_2.111.10.2org.apache.flinkflink-clients_2.111.10.2注意事项:在 FLINK-18242 之后 , 过时的类OptionsFactory和ConfigurableOptionsFactory会被移除(不适用于 release-1.10 系列) , 请使用RocksDBOptionsFactory和ConfigurableRocksDBOptionsFactory代替 。 如果任何类扩展了DefaultConfigurableOptionsFactory , 也请重新编译应用程序代码 。
默认情况下 , 在 FLINK-17800 之后 , 会为 RocksDB的ReadOptions将setTotalOrderSeek设置为 true , 以防止用户误用optimizeForPointLookup 。 同时支持ReadOptions通过RocksDBOptionsFactory进行自定义 。 如果观察到出现任何性能下降的情况 , 请重新设置setTotalOrderSeek为 false(根据测试通常不会发生) 。
部分更新内容
【车驰夜幕|Apache Flink 1.10.2发布,官方强烈建议升级】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] - 删除配置单元连接器的过时文档
详情查看 下载地址