本文为您介绍2021-08-04号发布的Flink全托管版本的重大功能变更和主要缺陷修复。

VVP 2.5.7版本重大功能变更

  • 作业停止后会清理该作业生成的所有Checkpoint,因此如果您需要恢复作业的状态,可以采取以下任何一种方式:
    • 暂停作业后再恢复作业。
    • 停止后从Savepoint恢复作业。
  • 新增
    • 开发类功能
      • SQL作业支持配置细粒度资源,即可以配置CPU和内存到Share Slot上。详情请参见配置细粒度资源
      • 上线作业时,支持生成开发版本,您可以进行版本比较、回滚历史版本等操作。详情请参见管理作业版本
      • 支持Hologres元数据,可以通过注册Hologres Catalog直接访问下游Hologres表。详情请参见管理Hologres Catalog
      • 引擎版本命名格式变更为vvr-<vvr版本号>-flink-<flink版本号>
      • 支持提交多个不同引擎版本的SQL作业。目前仅支持vvr-3.0.3-flink-1.12vvr-4.0.8-flink-1.13两个版本。
        说明 从VVR 3.0.3版本(对应Flink 1.12版本)开始,VVP支持同时运行多个不同引擎版本的SQL作业。如果您的作业已使用了Flink 1.12及更早版本的引擎,您需要按照以下情况进行处理:
        • Flink 1.12版本:停止后启动作业,系统将自动将引擎升级为vvr-3.0.3-flink-1.12版本。
        • Flink 1.11或Flink 1.10版本:手动将作业引擎版本升级到vvr-3.0.3-flink-1.12vvr-4.0.8-flink-1.13版本后重启作业,否则会在启动作业时超时报错。
    • 运维类功能
      • 支持自定义设置报警频率。
      • 支持设置Webhook报警。
  • 优化
    • 优化上传JAR包的方式,提高上传速度。
    • 下载到SLS的日志中新增作业名称标签,方便定位作业问题。

VVR 4.0.8版本重大功能变更

  • 支持Holo Catalog。
  • 支持细粒度资源配置。
  • 云数据库RDS MySQL Connector JDBC版本升级,兼容更多字符集。
  • MySQL的CDC Connector支持多并发读取全量数据、无锁算法和断点续传功能。
  • 云原生数据仓库AnalyticDB MySQL版3.0 Connector支持ON Depulicate Key Update语义。

VVR 4.0.8版本主要缺陷修复

修复Kafka currentEmitEventTimeLag在某些Partition没有数据时显示Log.MAX的异常。