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

VVP重大功能变更

  • 新增SQL结果预览(SQL Preview):DML语句可以在SQL编辑器内直接运行,具备基础的调试能力,提升代码开发效率。详情请参见作业调试
  • 新增用户自定义连接器(User-Defined Connector):对于系统不支持的Source或者Sink,您可以快速扩展新连接器满足需求。详情请参见管理自定义Connectors
  • 新增Session集群(Session-Cluster):您可自定义Session集群,Session集群可以复用JM资源节省小作业资源消耗,并支持较快地提交作业,适合SQL结果预览等运行时间较短的使用场景。详情请参见配置开发测试环境(Session集群)

VVR 2.1.2重大功能变更

  • 支持TTL设置,在其他参数中配置table.exec.state.ttl: 129600000(单位为毫秒)。
  • 支持Print Connector,您可以进行线上调试。
  • 支持RocketMQ源表声明计算列。
  • 支持MaxCompute源表,详情请参见增量MaxCompute源表

VVR 2.1.2主要缺陷修复

  • 修复Hologres Connector DDL上设置了某个字段为Not Null时,引起作业运行Failover的缺陷。
  • 修复RDS因batchSize参数默认值5000过大,导致上游数据量过少而不下发数据的缺陷。
  • 修复Flink Kafka Connector中存在的缺陷,当从Checkpoint或Savepoint恢复时,没有调用DeserializationSchema#open() 方法导致Failover:NullPointerException问题。
  • 修复OTS结果表因WITH参数大小写不正确验证报错的缺陷。