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-...