管理作业版本
登录 实时计算控制台。在 Flink全托管 页签，单击目标工作空间 操作 列下的 控制台。在左侧导航栏，单击 SQL开发。双击目标作业名称。在页面右侧，单击 版本信息。在目标版本号对应的 操作 列，单击 对比。在左侧 选择版本 中选择目标对比...
概述
例如，需要统计在过去的1分钟内有多少用户单击了某个网页，可以通过定义一个窗口来收集最近1分钟内的数据，并对这个窗口内的数据进行实时计算。Flink SQL支持的窗口聚合主要是两种：Window聚合和Over聚合。本文档主要为您介绍Window聚合。...
资源抵扣包
免费试用：实时计算Flink版新用户可以在 免费试用 页面，单击实时计算Flink版卡片上的 立即试用，根据页面提示领取5000 CUH资源抵扣包，开通Flink进行试用。试用完毕后请及时释放不需要的资源，避免产生额外费用。59元优惠：在 产品规格 ...
Flink SQL作业快速入门
已创建Flink工作空间，详情请参见 开通实时计算Flink版。步骤一：创建作业 进入SQL作业创建页面。登录 实时计算控制台。单击目标工作空间 操作 列下的 控制台。在左侧导航栏，单击 SQL开发。单击 新建。单击 空白的流作业草稿。Flink也为您...
Datastream JAR迁移
本文为您介绍如何将自建Flink集群上的Datastream JAR作业，迁移至实时计算Flink全托管的JAR作业类型中。背景信息 本文介绍的迁移场景如下图所示。前提条件 本地已安装Maven 3.x。已在 Maven资源中心 下载了开源JDBC Connector包，包括 ...
迁移方案
本文为您介绍阿里云实时计算Blink独享或共享集群（Blink计算引擎和Bayes开发平台）的业务迁移至实时计算Flink全托管（Flink计算引擎VVR和开发平台VVP）时的迁移限制、迁移方案和常见问题。迁移限制 由于Blink作业的State和Flink的State无法...
2024-03-13版本
同城高可用 开通实时计算Flink版 资源调整 管理项目空间 修改虚拟交换机 算子探查（公测）支持对运行中的SQL作业进行中间结果查询，减少排查数据正确性的难度。算子探查（公测）免费监控服务 开通Flink工作空间时，支持选择免费监控服务，...
管理StarRocks Catalog
详情请参见 基于实时计算Flink使用CTAS&CDAS功能同步MySQL数据至StarRocks。删除StarRocks Catalog UI方式 进入元数据管理页面。登录 实时计算控制台。在 Flink全托管 页签，单击目标工作空间 操作 列下的 控制台。单击 元数据管理。在 ...
配置监控告警
实时计算Flink版默认使用云监控（免费监控服务）或ARMS提供监控报警服务，配置作业指标或事件监控告警，便于您及时发现并处理异常。本文为您介绍使用不同监控服务时如何配置监控告警。使用限制 部署时提交至Session集群的Flink作业不支持...
Confluent Avro
本文为您介绍Confluent Avro格式的使用方法、配置选项和类型映射。背景信息 Confluent Avro格式允许读取被io.confluent.kafka.serializers.KafkaAvroSerializer序列化的记录，以及写入能被io.confluent.kafka.serializers....
StarRocks
CDAS可以实现整库同步或者同一库中的多表结构和数据同步，详情请参见 基于实时计算Flink使用CTAS&CDAS功能同步MySQL数据至StarRocks。前提条件 已创建StarRocks集群，包括EMR的StarRocks或基于ECS的云上自建StarRocks。使用限制 仅实时计算...
查看与修改作业运行状态
本文为您介绍如何查看和修改作业运行状态，以及不同状态所代表的含义。前提条件 其他阿里云账号或RAM用户共同使用实时计算Flink版产品时，需要为阿里云账号或RAM用户授权，以进行查看与修改作业运行状态等相关操作，详情请参见 作业操作...
企业级状态后端存储配置
说明 企业级状态后端存储的整体介绍和配置方法，详情请参见 企业级状态后端存储介绍 和 设置State相关参数。基本配置 参数 说明 数据类型 默认值 备注 table.exec.state.ttl SQL作业的State TTL（Time To Live）。Long 实时计算引擎VVR 4.0...
开通实时计算Flink版
使用实时计算Flink版需要开通工作空间，每个工作空间的计算资源隔离，开发控制台相互独立。本文为您介绍开通Flink工作空间的操作步骤，以及开通过程中的注意事项。前提条件 已拥有阿里云账号。如果您还没有阿里云账号，请先完成注册，详情...
云消息队列 RocketMQ 版
本文为您介绍 云消息队列 RocketMQ 版 连接器。重要 鉴于 云消息队列 RocketMQ 版 4.x标准版当前最高可达每秒5千条消息的限速机制，使用该版作为实时计算Flink版对接的消息中间件，可能会导致Flink作业运行不稳定。因此，在选择消息中间件...
Table/SQL JAR迁移至SQL
实时计算Flink全托管版集群内置了商业化的RDS Connector，您也可以替换为开源JDBC Connector。商业化的RDS Connector详情请参见 云数据库RDS MySQL结果表。本文介绍的迁移场景如下图所示。前提条件 本地已安装Maven 3.x。已在 Maven资源...
BITNOT
使用限制 仅实时计算引擎VVR 3.0.0及以上版本支持BITNOT函数。语法 INT BITNOT(INT number)说明 输入和输出类型均为整型，且类型一致。入参 参数 数据类型 number INT 示例 测试数据 a(INT)7 测试语句 SELECT BITNOT(a)as var1 FROM T1;...
云原生数据仓库AnalyticDB PostgreSQL版（ADB PG）
使用限制 仅Flink实时计算引擎VVR 6.0.0及以上版本支持云原生数据仓库AnalyticDB PostgreSQL版连接器。仅Flink实时计算引擎VVR 8.0.1及以上版本支持云原生数据仓库AnalyticDB PostgreSQL版7.0版本。暂不支持自建的Postgres SQL。语法结构 ...
作业状态集管理
系统检查点（Checkpoint）和作业快照（Savepoint）统称为状态集。...相关文档 实时计算Flink版系统检查点或作业快照相关的常见问题，请参见 系统检查点或作业快照。SQL修改所造成的兼容性影响详情，请参见 SQL修改及兼容性。
BITAND
使用限制 仅实时计算引擎VVR 3.0.0及以上版本支持BITAND函数。语法 INT BITAND(INT number1,INT number2)说明 输入和输出类型均为整型，且类型一致。入参 参数 数据类型 number1 INT number2 INT 示例 测试数据 a(INT)b(INT)2 3 测试语句 ...
BITOR
使用限制 仅实时计算引擎VVR 3.0.0及以上版本支持BITOR函数。语法 INT BITOR(INT number1,INT number2)入参 参数 数据类型 number1 INT number2 INT 说明 输入和输出类型均为整型，且类型一致。示例 测试数据 a(INT)b(INT)2 3 测试语句 ...
Blackhole
类别 详情 支持类型 结果表 运行模式 批模式和流模式 数据格式 暂不适用 特有监控指标 暂无 API种类 SQL 是否支持更新或删除结果表数据 是 使用限制 仅Flink计算引擎VVR 2.0.0及以上版本支持Blackhole连接器。语法结构 CREATE TABLE ...
BITXOR
使用限制 仅实时计算引擎VVR 3.0.0及以上版本支持BITXOR函数。语法 INT BITXOR(INT number1,INT number2)入参 参数 数据类型 number1 INT number2 INT 说明 输入和输出类型均为整型，且类型一致。示例 测试数据 a(INT)b(INT)2 3 测试语句 ...
网络架构升级
为了提高服务质量并满足不断增长的业务需求，我们将对实时计算Flink版网络架构进行重要升级。此次升级旨在优化IP资源的使用效率，加强网络安全隔离措施，并为支持同城高可用CU类型奠定基础，为您带来更加稳健和高效的数据处理体验。您可以...
其他限制
当前作业的Flink版本和产生Checkpoint或Savepoint对应作业的Flink版本要求相同，不同的Flink版本当前不支持状态兼容性检查。当前作业的依赖和产生Checkpoint或Savepoint对应作业的依赖要求能兼容。当前系统无法识别自定义Connector、自定义...
查看启动和运行日志
在Flink UI页面查看运行日志 登录 实时计算控制台。在 Flink全托管 页签，单击目标工作空间 操作 列下的 控制台。在左侧导航栏上，选择 作业运维。单击目标作业名称。在 状态总览 页面，单击 Flink UI。在左侧导航栏，单击 Task Managers ...
搭建基础环境
鼠标悬浮在 开源Flink迁移实时计算Flink全托管版 上，单击 基于方案新建。修改EMR-Flink集群密码。说明 本文使用EMR-Flink作为用户自建Flink集群来运行迁移前的作业，以此来对比验证自建Flink迁移后的作业运行结果。如果您已经有了自建...
功能发布记录
Flink产品重大变更或者活动公告信息请在 实时计算控制台 或者 实时计算Flink版产品公告 上进行查看。企业级状态后端存储GeminiStateBackend，以及其与RocksDBStateBackend的性能对比情况，请参见 企业级状态后端存储介绍。
包年包月
包年包月是一种先付费后使用的计费方式，在购买时根据购买时长预先支付了费用。适用于具有长期稳定，可预估资源使用周期的业务场景。本文为您介绍包年包月付费模式的计费规则、计费周期和...开通工作空间操作，请参见 开通实时计算Flink版。
计费概述
本文介绍Flink全托管的计费项、计费方式、欠费说明、续费说明、退款说明、查看账单和计费常见问题。相关项 说明 相关文档 计费项 为您介绍Flink全托管产品的资源估算、计费项以及相关计算公式，以便您对支付的费用组成有所了解。计费项 ...
Avro
支持Avro格式的连接器包括 消息队列Kafka、Upsert Kafka 和 对象存储OSS。使用示例 利用Kafka以及Avro格式构建表的示例如下。CREATE TABLE user_behavior(user_id BIGINT,item_id BIGINT,category_id BIGINT,behavior STRING,ts TIMESTAMP...
项目空间授权
角色支持的功能 实时计算Flink版支持添加阿里云账号、RAM用户、RAM角色账号扮演的阿里云主账号为成员，并对添加的成员绑定owner、editor或viewer角色。不同角色可以使用的功能差异如下表所示。功能 owner editor viewer 查看作业列表 Y Y Y...
Raw
本文为您介绍Raw格式的使用方法、配置选项和类型映射。背景信息 Raw格式允许读写基于字节的原始值作为单个列。Raw格式连接器是内置的。支持Raw格式的连接器包括 消息队列Kafka、Upsert Kafka 和 对象存储OSS。使用方法 例如，在Kafka中具有...
使用内置公开数据集快速体验实时计算Flink版
本文为您介绍如何基于阿里云实时计算Flink版内置的GitHub公开事件样例数据，快速体验实时计算Flink版产品的实时数据分析功能。注意事项 如果您是实时计算Flink版新用户，可以申请该产品的免费资源包，免费试用体验实时计算Flink版产品的...
查询脚本
操作步骤 登录 实时计算控制台。在 Flink全托管 页签，单击目标工作空间 操作 列下的 控制台。在 SQL开发 页面，单击 查询脚本 页签。单击，新建查询脚本。填写SQL代码。支持Call命令和DDL、DQL、DML语法。默认使用批模式，您可以使用如下...
REGEXP_REPLACE
使用限制 仅实时计算引擎VVR 3.0.0及以上版本支持REGEXP_REPLACE函数。语法 VARCHAR REGEXP_REPLACE(VARCHAR str,VARCHAR pattern,VARCHAR replacement)入参 参数 数据类型 说明 str VARCHAR 指定的字符串。pattern VARCHAR 被替换的字符串...
迁移方案
本文为您介绍将自建开源Flink集群的流式作业（包含Table API、SQL和Datastream）迁移至阿里云实时计算Flink全托管版的迁移优势、迁移方案和相关文档。迁移优势 Flink全托管产品按CU售卖，根据业务需要按需购买，可以降低成本。另外提供提交...
管理资源队列
每个Flink项目空间都会有一个默认队列（default-queue）来承载作业的运行。如果您有资源隔离和管理的需求，可以通过添加资源队列的方式实现。本文为您介绍如何添加、修改和删除资源队列。使用场景及方式 适用于有资源隔离和管理需求的场景...
Parquet
仅对象存储OSS连接器（实时计算引擎VVR 6.0.7及以上版本）支持读取Parquet格式的数据。使用示例 利用OSS和Parquet格式创建表的示例如下。CREATE TABLE user_behavior(user_id BIGINT,item_id BIGINT,category_id BIGINT,behavior STRING,ts...
代码模板
Flink全托管为您提供了丰富的代码模板，每种代码模板都为您提供了具体的使用场景、代码示例和使用指导。您可以通过代码模板快速地了解Flink产品功能和相关语法，实现自己的业务逻辑。本文为您介绍代码模板的使用场景和操作步骤。使用限制 ...
- 产品推荐
- 这些文档可能帮助您