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