概述
实时计算Flink版支持在Flink SQL作业中使用Java自定义函数，本文介绍Flink Java自定义函数的分类、参数传递及调用注意事项。注意事项 为了避免JAR包依赖冲突，在开发自定义函数时您需要注意以下几点：SQL开发页面选择的Flink版本，请和Pom...
管理Paimon Catalog
Paimon Catalog使用的OSS Bucket必须与实时计算Flink版位于同一地域，且开通实时计算Flink版服务的账号必须有权限读写该OSS Bucket。注意事项 目前由于Flink全托管相关缓存机制，通过SQL方式进行Catalog、Database和table的增删，无法立刻...
开通与计费常见问题
本文介绍Flink全托管开通与计费方面的常见问题。为什么前往RAM授权，但无法跳转到RAM控制台？报错：Message:Forbidden!Configured service account doesn't have access.Service account may have been revoked.pods"job-*-taskmanager-2-5...
如何关闭对实时计算Flink版的监控？
若您不再需要对实时计算Flink版进行监控，您可以按照以下步骤卸载实时计算Flink版。登录 ARMS控制台。在左侧导航栏选择 Prometheus监控>Prometheus实例列表，进入可观测监控 Prometheus 版的实例列表页面。单击 实例类型 为 Prometheus for...
开通与计费常见问题
本文介绍Flink全托管开通与计费方面的常见问题。为什么前往RAM授权，但无法跳转到RAM控制台？报错：Message:Forbidden!Configured service account doesn't have access.Service account may have been revoked.pods"job-*-taskmanager-2-5...
配置监控告警
实时计算Flink版默认使用云监控（免费监控服务）或ARMS提供监控报警服务，配置作业指标或事件监控告警，便于您及时发现并处理异常。本文为您介绍使用不同监控服务时如何配置监控告警。使用限制 部署时提交至Session集群的Flink作业不支持...
Datastream JAR迁移
本文为您介绍如何将自建Flink集群上的Datastream JAR作业，迁移至实时计算Flink全托管的JAR作业类型中。背景信息 本文介绍的迁移场景如下图所示。前提条件 本地已安装Maven 3.x。已在 Maven资源中心 下载了开源JDBC Connector包，包括 ...
环境准备
背景信息 阿里云实时计算Flink版是一套基于Apache Flink构建的⼀站式实时大数据分析平台，提供端到端亚秒级实时数据分析能力，并通过标准SQL降低业务开发门槛，助力企业向实时化、智能化大数据计算升级转型。更多信息，请参见 什么是阿里云...
Flink动态CEP快速入门
实时计算Flink版支持通过DataStream作业的方式运行支持规则动态更新的Flink CEP作业。本文结合实时营销中的反作弊场景，为您介绍如何基于Flink全托管快速构建一个动态加载最新规则来处理上游Kafka数据的Flink CEP作业。背景信息 在电商平台...
SQL作业开发
登录 实时计算控制台。在 Flink全托管 页签，单击目标工作空间 操作 列下的 控制台。在 SQL开发 页面，单击 新建。单击 空白的流作业草稿。Flink全托管为您提供了丰富的SQL代码模板和数据同步模板，每种模板都为您提供了使用场景、代码示例...
概述
例如，需要统计在过去的1分钟内有多少用户单击了某个网页，可以通过定义一个窗口来收集最近1分钟内的数据，并对这个窗口内的数据进行实时计算。Flink SQL支持的窗口聚合主要是两种：Window聚合和Over聚合。本文档主要为您介绍Window聚合。...
搭建基础环境
鼠标悬浮在 开源Flink迁移实时计算Flink全托管版 上，单击 基于方案新建。修改EMR-Flink集群密码。说明 本文使用EMR-Flink作为用户自建Flink集群来运行迁移前的作业，以此来对比验证自建Flink迁移后的作业运行结果。如果您已经有了自建...
迁移方案
本文为您介绍阿里云实时计算Blink独享或共享集群（Blink计算引擎和Bayes开发平台）的业务迁移至实时计算Flink全托管（Flink计算引擎VVR和开发平台VVP）时的迁移限制、迁移方案和常见问题。迁移限制 由于Blink作业的State和Flink的State无法...
通过实时计算Flink集成向量数据
若实时计算Flink端使用开源自建版，请确保 flink-adbpg-connector 已安装在$FLINK_HOME/lib 目录下。若使用 公有云托管版，则无任何操作。AnalyticDB PostgreSQL版 数据库已安装向量检索插件FastANN。您可以在psql客户端通过 \dx fastann ...
概述
Flink全托管提供状态兼容性检查和状态数据迁移功能。本文为您介绍Flink全托管兼容性判断的结果详情，以及RocksDB和Gemini两种StateBackend在状态数据迁移时的迁移效率和作业表现方面的区别。背景信息 Flink作业是通过状态数据（包括...
管理StarRocks Catalog
详情请参见 基于实时计算Flink使用CTAS&CDAS功能同步MySQL数据至StarRocks。删除StarRocks Catalog UI方式 进入元数据管理页面。登录 实时计算控制台。在 Flink全托管 页签，单击目标工作空间 操作 列下的 控制台。单击 元数据管理。在 ...
BITNOT
使用限制 仅实时计算引擎VVR 3.0.0及以上版本支持BITNOT函数。语法 INT BITNOT(INT number)说明 输入和输出类型均为整型，且类型一致。入参 参数 数据类型 number INT 示例 测试数据 a(INT)7 测试语句 SELECT BITNOT(a)as var1 FROM T1;...
日志服务SLS
说明 实时计算Flink版默认不具备访问公网的能力，但阿里云提供的NAT网关可以实现VPC网络与公网网络互通，详情请参见 Flink全托管如何访问公网？project SLS项目名称。String 是 无 无。logStore SLS LogStore或metricstore名称。String 是 ...
管理Hologres Catalog
实时计算Flink版仅支持读写Hologres内表，因此Hologres实例必须是独占实例，不支持 Hologres共享集群实例。创建Hologres Catalog 支持UI与SQL命令两种方式配置Hologres Catalog，推荐使用UI方式配置Hologres Catalog。UI方式（推荐）进入...
Table/SQL JAR迁移至SQL
实时计算Flink全托管版集群内置了商业化的RDS Connector，您也可以替换为开源JDBC Connector。商业化的RDS Connector详情请参见 云数据库RDS MySQL结果表。本文介绍的迁移场景如下图所示。前提条件 本地已安装Maven 3.x。已在 Maven资源...
企业级状态后端存储配置
在实时计算引擎VVR 4.0.x版本中，如果您发现Join作业的Join成功率比较低而Value又比较大时，则可以将该参数取值设置为GLOBAL_ENABLE，进而取得更好的性能。您可以通过Join节点的Records Received和Records Sent的比例，大致估算Join成功率...
BITOR
使用限制 仅实时计算引擎VVR 3.0.0及以上版本支持BITOR函数。语法 INT BITOR(INT number1,INT number2)入参 参数 数据类型 number1 INT number2 INT 说明 输入和输出类型均为整型，且类型一致。示例 测试数据 a(INT)b(INT)2 3 测试语句 ...
BITAND
使用限制 仅实时计算引擎VVR 3.0.0及以上版本支持BITAND函数。语法 INT BITAND(INT number1,INT number2)说明 输入和输出类型均为整型，且类型一致。入参 参数 数据类型 number1 INT number2 INT 示例 测试数据 a(INT)b(INT)2 3 测试语句 ...
BITXOR
使用限制 仅实时计算引擎VVR 3.0.0及以上版本支持BITXOR函数。语法 INT BITXOR(INT number1,INT number2)入参 参数 数据类型 number1 INT number2 INT 说明 输入和输出类型均为整型，且类型一致。示例 测试数据 a(INT)b(INT)2 3 测试语句 ...
功能与优势
本文为您介绍阿里云实时计算Flink全托管产品的功能点和价值，以及和开源Flink的对比优势。类型 功能 描述 价值 性能与成本 兼容性 全面兼容开源Flink，包括各层API、参数配置及SQL语法等。更好的引擎性能和更细粒度资源配置使得整体TCO优于...
准备工作
本文介绍场景中RDS MySQL、实时计算Flink和表格存储产品的准备工作。使用RDS MySQL服务 首次使用RDS MySQL时，请根据如下步骤创建RDS MySQL实例以及创建数据库和账号等。创建RDS MySQL实例。具体操作，请参见 创建RDS MySQL实例。创建数据...
RAM授权
通过RAM用户或者RAM角色等方式访问实时计算控制台，并进行购买、查看或者删除工作空间等操作时，需要拥有相应的权限。本文为您介绍Flink支持的权限策略类型、以及如何进行RAM授权。权限策略类型 权限策略是用语法结构描述的一组权限的集合...
实时数据集成（Flink版）
本文介绍使用实时计算Flink版的连接器功能集成物联网平台实例下数据服务中数据的完成流程。前提条件 已完成实时计算Flink版服务开通和准备工作。如果您使用RAM用户或RAM角色等身份访问，需要确认已具有Flink控制台相关权限，详情请参见 ...
2022-09-19版本
本文为您介绍2022年9月19日发布的Flink全托管版本的重大功能变更和主要缺陷修复。概述 2022年9月19日正式对外发布全托管Flink的新版本，包含平台和引擎的更新、Connector的更新、性能优化以及缺陷修复。本次发布的是基于Flink 1.13的VVR-4....
重大语义变更
本文为您介绍Flink在Blink的基础上发生的重大的语义变更详情。Flink在Blink的基础上发生的重大的语义变更，包括以下方面：Timestamp类型变更 Bigint列不能作为时间属性列 自定义函数需要额外的类型提示 Int类型整除结果类型变动 参数大小写...
包年包月
包年包月是一种先付费后使用的计费方式，在购买时根据购买时长预先支付了费用。适用于具有长期稳定，可预估资源使用周期的业务场景。本文为您介绍包年包月付费模式的计费规则、计费周期和...开通工作空间操作，请参见 开通实时计算Flink版。
通过Flink导入数据
功能介绍 Flink Doris Connector是云数据库 SelectDB 版流式导入数据的常用方式。基于Flink的流处理能力，您可以将上游数据源（MySQL、PostgreSQL、Kafka等）中的大量数据，通过Flink Doris Connector导入到SelectDB表中。同时，您也可以...
ISNAN
使用限制 仅实时计算引擎VVR 3.0.0及以上版本支持ISNAN函数。语法 BOOLEAN ISNAN(DOUBLE d)BOOLEAN ISNAN(FLOAT f)入参 参数 数据类型 d DOUBLE f FLOAT 示例 测试数据 表 1.T1 d f 0.1 0.1 0 0 测试语句 SELECT ISNAN(CAST(d AS DOUBLE))...
管理作业版本
登录 实时计算控制台。在 Flink全托管 页签，单击目标工作空间 操作 列下的 控制台。在左侧导航栏，单击 SQL开发。双击目标作业名称。在页面右侧，单击 版本信息。在目标版本号对应的 操作 列，单击 对比。在左侧 选择版本 中选择目标对比...
如何关闭对实时计算Flink版的监控？
若您不再需要对实时计算Flink版进行监控，您可以按照以下步骤卸载实时计算Flink版。登录 Prometheus控制台。在左侧导航栏单击 实例列表，进入可观测监控 Prometheus 版的实例列表页面。单击 实例类型 为 Prometheus for Flink Serverless ...
查看启动和运行日志
在Flink UI页面查看运行日志 登录 实时计算控制台。在 Flink全托管 页签，单击目标工作空间 操作 列下的 控制台。在左侧导航栏上，选择 作业运维。单击目标作业名称。在 状态总览 页面，单击 Flink UI。在左侧导航栏，单击 Task Managers ...
基于Flink+Paimon搭建流式湖仓
本文为您介绍如何通过实时计算Flink版和流式数据湖仓Paimon搭建流式湖仓。背景信息 随着社会数字化发展，企业对数据时效性的需求越来越强烈。传统的离线数仓搭建方法论比较明确，通过定时调度离线作业的方式，将上一时段产生的新鲜变更并入...
作业状态集管理
系统检查点（Checkpoint）和作业快照（Savepoint）统称为状态集。...相关文档 实时计算Flink版系统检查点或作业快照相关的常见问题，请参见 系统检查点或作业快照。SQL修改所造成的兼容性影响详情，请参见 SQL修改及兼容性。
作业引擎版本升级
本文将为您介绍如何升级实时计算Fllink版作业的引擎版本。注意事项 实时计算Fllink版引擎发布前，会进行丰富的兼容性测试，原则上同一大版本下的小版本间升级是兼容的，大版本间升级不保证兼容。引擎版本详情请参见 引擎版本号及其含义。...
支持的登录方式
本文为您介绍Flink控制台支持的登录方式。登录类型 说明 登录方式 如何登录 阿里云账号（主账号）阿里云账号（主账号）是阿里云资源的归属及使用计量计费的基本主体，将作为阿里云系统用于识别资源消费的账号，拥有所购买产品的所有权限。...
- 产品推荐
- 这些文档可能帮助您