本文为您介绍2023年2月20日发布的实时计算Flink版的重大功能变更和主要缺陷修复。
概述
2023年2月20日正式对外发布实时计算Flink版的新版本。本次发布的是基于Apache Flink 1.15.3的VVR 6.0.5版本。该版本包含了Apache Flink 1.15.3全部的缺陷修复。同时,正式发布StarRocks连接器,方便对StarRocks进行结果表写入和源表读取。
功能介绍
特性 | 详情 | 相关文档 |
Flink CDC 实时数据入湖入仓支持非严格的类型对应 | 您在使用CDAS、CTAS语法进行数据入湖入仓时上下游的列类型可以在兼容的情况下不严格对应,避免不必要的报错,目前支持此功能的下游为Hologres。 | |
Flink SQL CEP支持Group Pattern和NO SKIP的单个元素多次匹配 | 支持类似A(B C)+ 的Group模式和A B{4,10}? 的NO SKIP模式。 | |
SLS连接器支持指定Bucket数量和从指定的消费组中保存的Checkpoint开始消费日志 | SLS连接器通过指定Bucket数量对Shard数在64以上的Logstore进行了支持,同时支持了从指定的消费组中保存的Checkpoint开始消费日志的选项。 | |
新增StarRocks连接器 | 支持将StarRocks作为结果表和源表进行操作。 | 暂无 |
CTAS方式同步过程加入op_ts等meta信息 | 在CTAS中,支持同步op_ts等meta信息的能力。 |
缺陷修复
修复修改作业中Kafka的WITH参数后启动任务可能导致启动失败的缺陷。
修复Flink CDC在异步线程里用JDBC读数据库时,出现OOM无法透出的缺陷。
修复由于错误的codeGen代码而出现
Table program cannot be compiled.
的问题。