2022-12-26版本
本文为您介绍2022年12月26日发布的实时计算Flink版的重大功能变更和主要缺陷修复。
概述
2022年12月26日正式对外发布实时计算Flink版的新版本。本次发布的是基于Apache Flink 1.15.2的VVR 6.0.4版本。该版本新增了Hologres 连接器、MySQL CDC 连接器的众多功能,以及进行了动态CEP的能力增强和易用性优化。
如果您的作业使用了VVR 6.0.4以下版本,建议您尽快将VVR版本升级至VVR 6.0.4,以确保生产的稳定运行。
功能介绍
MySQL CDC与PostgreSQL CDC支持Flink CDC社区2.3版本提供所有功能。
MySQL CDC 连接器新增支持指定binlog的消费位点。
Hologres 连接器 Binlog模式新增支持timestamp。
Hologres Catalog新增支持alter table语句,来修改Hologres表的属性。
Hologres 连接器源表新增支持filter下推,不会全量读取Hologres源表,优化大数据量下的读取性能。
动态CEP新增支持通过within语法定义事件之间的时间间隔。
动态CEP新增支持在JSON格式的规则描述中支持Condition接收参数。
优化动态CEP的部分功能:优化遇到不支持的Condition时的报错提示;当AviatorCondition解析到错误Pattern时,忽略而不是作业失败。
增强了静态CEP的SQL MatchRocognize能力,支持SHOW TIMEOUT MATCHES ,Not Next,Consecutive,Until,Followed By,Followed By Any和Not Followed By等语法。
Kafka Source 连接器新增支持校验本作业指定消费组是否与已有消费组重复。
新增SLS Datastream 连接器的支持,详情请参见SLS DataStream 连接器。
缺陷修复
优化MySQL CDC 连接器 Binlog无法消费、server_id重复的异常报错信息。
修复1.27版snakeyaml的CVE-2022-25857漏洞。
优化NPE、数组越界等真实异常信息之前隐藏过深等问题。