本文为您介绍2022年12月12日发布的实时计算Flink版的重大功能变更和主要缺陷修复。
概述
2022年12月12日正式对外发布实时计算Flink版的新版本。本次发布的是基于Apache Flink 1.15.2的VVR 6.0.3版本。该版本修复了一些Apache Flink社区的重大缺陷。同时平台新增了错误日志查询能力，您可以选择在日志中划词查询对应的异常。
如果您的作业使用了VVR 6.0.3以下版本，建议您尽快将VVR版本升级至VVR 6.0.3，以确保生产的稳定运行。
功能介绍
新增异常划词查询能力，您可以在作业运行事件、作业探查中找到相关日志，划词选中其中段落进行查询。通过查询您可以获取到错误原因和解决方案。
支持增加或删除CDAS作业非空列的变更。
在使用Kafka JSON Catalog推断Schema时，新增支持保持列的顺序一致。
在写入MaxCompute数据时，支持可配置重试机制，以避免在Tunnel集群出现闪断情况，导致flink commit或者createuploadsession失败的问题。
新增对于RDS 数据库创建新表错误语法的兼容能力，出现此类问题不再影响正在运行的Flink CDC任务。
优化SQL语法校验的错误提示。
缺陷修复
解决CDAS同步到Kafka时，sink.parallelism不生效的问题。
修复6.0.2版本上CDAS作业ClassCastException报错问题。
修复6.0.2版本上MySQL CDC源表延时曲线不显示的问题。
修复6.0.2版本上SQL Hints语法不生效的问题。
修复6.0.2版本上语法检查时将类冲突异常错误抛出为数据越界异常的问题。
修复6.0.2版本上CTAS作业一张表写多个Sink时Server ID冲突的问题。
修复部分情况下K8s leader选举造成的JM死锁的问题。
修复状态后端Gemini的Decrease reference to an unknown file异常。