全部产品
Search
文档中心

实时计算Flink版:2023-04-13版本

更新时间:Jun 05, 2024

本文为您介绍2023年4月13日发布的实时计算Flink版的重大功能变更和主要缺陷修复。

重要

本次版本将在全网进行分步骤的灰度,全网更新发布的时间预计为2023年4月13日至2023年8月15日。如果您未能在控制台上找到相关新功能,说明您的平台暂未完成灰度。如果您需要尽快升级,请提交工单告知我们,我们将结合实际情况进行安排。具体升级计划,请关注实时计算控制台页面右侧的最新公告。

概述

2023年4月13日正式对外发布实时计算Flink版的新版本,包含平台改版和引擎更新、连接器更新、性能优化以及缺陷修复。

引擎侧将正式对外发布VVR 6.0.6版本,该版本是基于Apache Flink 1.15.3的企业级Flink引擎。作为预览型功能,自本版本起,阿里云实时计算Flink提供了Apache Paimon (incubating),这是一项流式数据湖存储技术,提供高吞吐、低延迟的数据摄入、流式订阅和实时查询能力。

平台侧将进行多项常用功能的改版,更改了开发控制台的一级目录和作业开发运维的流程,优化了产品的使用体验,增强了报警能力。

灰度完毕后,平台能力将完成升级。作业引擎版本将在两周内升级,升级完成后可以在作业的引擎列表中看到新引擎版本。欢迎您体验平台侧的新能力,将作业使用的引擎升级至新版本,期待您的反馈和使用体验。

功能介绍

特性

详情

相关文档

支持Apache Paimon流式数据湖

作为预览型功能,引擎支持了基于阿里云OSS的Paimon的数据读写。

Paimon

支持Apache Paimon Catalog

支持您基于内置的Apache Paimon Catalog,通过Flink SQL构建基于Flink的实时数据湖方案。

管理Paimon Catalog

支持OSS-HDFS流式写入

允许将数据从流式写入OSS-HDFS,提供更多数据存储支持。

对象存储OSS

监控指标调整

  • CPU指标变更

    • 新增JM CPU Usage指标。

    • 取消TM CPU Load和JM CPU Load指标。

      说明

      CPU Load不能反映CPU使用情况,CPU Usage会作为唯一CPU使用率的监控指标。

  • 连接器指标变更

    • Elasticsearch连接器新增numRecordsOut和numRecordsOutPerSecond指标,提高运行可观测性。

    • MySQL CDC连接器新增Enumerator指标

支持Tair结果表

支持Tair结果表,提供更多数据存储选项。

-

流SQL Explain功能增强

支持plan_advice模式,提供更详细的优化建议。

暂无

动态CEP优化

支持基于Groovy表达式的Condition,优化了NFA和SharedBuffer的实现,减少了Timer创建次数,提高了性能。

动态CEP中规则的JSON格式定义

支持Flink ML

作为预览型功能,引擎支持了Flink ML,提供更方便的实时机器学习功能。

-

作业开发流程优化

作业开发页面优化为SQL开发页面,提供SQL开发的平台:

  • 提供部署上线的隔离机制,避免开发SQL影响线上正在运行的作业。对于Jar和Python作业来说,开发与线上天然隔离,且不需要使用到SQL中的UDF、连接器和Catalog等组件,所以不需要部署上线的机制。

  • 优化Jar作业和Python作业创建流程。SQL开发页面不再提供Jar和Python作业的创建,您可以直接在作业运维页面部署Jar作业和Python作业。历史上在开发界面创建的Jar和Python作业草稿可以在作业归档中查找。

作业开发

Jar和Python作业部署优化

优化创建流程,Jar和Python作业可直接在作业运维页面部署。

作业启动流程优化

作业的资源和Flink Conf的相关配置放置在部署详情页面,您可以在不停止作业的情况下调配资源,启动阶段仅需要设置启动位点。

作业启动

新增元数据页面

Flink社区不推荐使用临时表,建议您使用Catalog来创建SQL作业,从而避免重复使用DDL。因此,本版本将元数据能力继续增强,您可以在SQL作业中更多使用元数据,方便管理SQL作业。

暂无

SQL作业调试流程优化

优化了SQL作业的调试流程,不再需要设置调试的Session集群,而是在作业调试阶段选择调试作业要使用的Session集群,避免作业多版本情况下需要频繁更换调试集群的问题。

作业调试

新增安全页面

将用户授权与密钥托管(原变量替换)的页面整合成为一个安全页面,您可以在安全页面完成平台安全相关设置。

变量和密钥管理

新增连接器页面

连接器作业独立页面放置,方便您查看不同引擎版本支持的连接器类型以及版本,同时管理自己的自定义连接器。

管理自定义连接器

提供作业失败的告警

并支持电话告警和联系人搜索能力

监控告警功能升级:

  • 支持您设置电话告警方式,对联系人提供搜索能力。

  • 支持了作业失败的告警。

配置监控告警

支持角色账号登录

支持您使用角色账号登录Flink控制台,不支持对角色账号设置权限,默认使用owner权限。

-

支持网络探测能力

支持您通过输入IP或者域名的方式检测Flink作业运行的环境与您的上下游系统是否联通。

暂无

支持自定义Catalog

通过Catalog的方式注册元数据后,在创建SQL的时候不需要再频繁使用DDL创建临时表,实时计算开发控制台已经内置了部分Catalog,您也可以自定义Catalog JAR后注册并使用。

-

智能诊断能力增强

本次提供了对作业开发过程和作业运行过程中产生的错误日志智能分析的能力,在日志界面查看信息时,系统会自动分析日志内容并提供可执行的操作建议。

作业智能诊断

SLS连接器客户端升级

优化了SLS连接器的性能和稳定性。

暂无

CEP SQL功能扩展

CEP SQL支持循环连续性声明和UNTIL语法连用。

暂无

缺陷修复

  • 修复作业调试时,针对NULL数据展示为TRUE的缺陷。

  • 修复注册多个元数据服务时,因为其中一个元数据服务不可用导致所有元数据服务异常的问题。

  • 修复作业从Session集群切Pre-Job时状态恢复报错的问题。

  • 修复Hologres维表对Hologres源表进行Join时的验证报错问题。

  • 修复SLS源表消费位点异常回退的问题。