Apache Flink 1.15.2 发布,流处理框架

Apache Flink 1.15.2 现已发布,这是 Flink 1.15 系列的第二个错误修复版本;此版本包括 30 个错误修复、漏洞修复和 Flink 1.15 相关的一些小改进。Apache Flink 是一个开源的流处理框架,适用于分布式、高性能的数据流应用。

具体更新内容如下:

Bug

  • FLINK-25097 ] - 当过滤条件为布尔类型时,内联接的错误
  • FLINK-26931 ] - Pulsar sink 的 producer 名称应该是唯一的
  • FLINK-27399 ] - Pulsar 连接器未正确设置开始消耗位置
  • FLINK-27570 ] - Checkpoint 路径错误不会导致作业停止
  • FLINK-27794 ] - 使用 MysqlCatalog 从 MySQL 获取的主键不正确
  • FLINK-27856 ] - 添加没有规范的 pod 模板会使作业管理器崩溃
  • FLINK-28027 ] - 将 Async Sink 的最大 flight messages 数初始化为低数以用于速率限制策略
  • FLINK-28057 ] - LD_PRELOAD 在 flink-docker 上被硬编码为 x64
  • FLINK-28226 ] - “运行 kubernetes pyflink 应用程序测试”在拉取图像时失败
  • FLINK-28239 ] - Table-Planner-Loader 无法访问 commons-math3
  • FLINK-28240 ] - 当 NetworkBufferPool 的总段数为 0 时,NettyShuffleMetricFactory#RequestedMemoryUsageMetric#getValue 可能会抛出 ArithmeticException
  • FLINK-28250 ] - exactly-once sink kafka 导致内存不足
  • FLINK-28269 ] - Kubernetes 测试失败,权限被拒绝
  • FLINK-28322 ] - DataStreamScanProvider 的新方法不兼容
  • FLINK-28357 ] - 恢复 Finished sources 时的 Watermark 问题
  • FLINK-28404 ] - 注解 @InjectClusterClient 与 RestClusterClient 不能正常工作
  • FLINK-28454 ] - 修复 KafkaSource 错误时间戳示例
  • FLINK-28577 ] - 1.15.1 web ui 控制台报告关于 checkpoint size 的错误
  • FLINK-28602 ] - StateChangeFsUploader 在启用压缩时无法正常关闭流
  • FLINK-28817 ] - 从 checkpoint 恢复时 HybridSource 中的 NullPointerException
  • FLINK-28835 ] - Savepoint 和 checkpoint 功能和限制表不正确
  • FLINK-28861 ] - Non-deterministic UID 生成可能会导致 restore 期间出现问题
  • FLINK-28880 ] - 修复 CEP 文档中关于循环模式的严格连续的错误结果
  • FLINK-28908 ] - 在 PyFlink 中,LIST 类型的编码器选择错误
  • FLINK-28978 ] - Kinesis 连接器不适用于新的 AWS 区域
  • FLINK-28994 ] - 为 Flink UI 启用 withCredentials

Improvement

  • FLINK-27199 ] - 将 Pulsar 升级到 2.10.0 以修复不稳定的 Pulsar 测试环境。
  • FLINK-27865 ] - 添加在 Kafka SQL 连接器文档中配置 SASL 和 SSL 的指南和示例
  • FLINK-28094 ] - 升级 AWS SDK 以支持 ap-southeast-3
  • FLINK-28140 ] - 通过添加 Python 示例改进文档
  • FLINK-28486 ] - [docs-zh] Flink FileSystem SQL Connector Doc 不正确

更多详情可查看:https://flink.apache.org/news/2022/08/25/release-1.15.2.html

 

展开阅读全文
发表评论

相关文章