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

VVP重大功能变更

  • 作业停止后会清理该作业生成的所有Checkpoint，因此如果您需要恢复作业的状态，可以采取以下任何一种方式：
    • 暂停作业后再恢复作业。
    • 停止后从Savepoint恢复作业。
  • 新增
    • 开发类功能
      • SQL作业支持配置细粒度资源，即可以配置CPU和内存到Share Slot上。详情请参见配置作业部署信息。
      • 上线作业时，支持生成开发版本，您可以进行版本比较、回滚历史版本等操作。详情请参见管理作业版本。
      • 支持Hologres元数据，可以通过注册Hologres Catalog直接访问下游Hologres表。详情请参见管理Hologres Catalog。
      • 引擎版本命名格式变更为vvr-<vvr版本号>-flink-<flink版本号>。
      • 支持提交多个不同引擎版本的SQL作业。目前仅支持vvr-3.0.3-flink-1.12和vvr-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.12或vvr-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的异常。