本文为您介绍Flink全托管SQL作业开发的限制说明和操作流程。
限制说明
- SQL编辑器提交的SQL作业,仅支持开源Flink V1.11版本。
- SQL支持的上下游存储(Connector)列表,请参见支持的上下游存储。
开发流程
为了方便您编写和管理Flink SQL作业,提高作业开发效率,Flink全托管产品为您提供Flink SQL的全套功能,包括元数据管理、UDF注册和SQL编辑器等。
在开发控制台上,Flink SQL作业开发流程为:注册表 > 编写SQL语句 > 验证> 运行。
- 登录实时计算统一控制台。
- 在Flink全托管页签,单击目标工作空间操作列下的开发控制台。
- 分别注册源表和结果表。您可以通过以下任何一种方式进行。
- 直接编写完整的建表语句
- 在左侧导航栏,单击SQL编辑器。
- 单击新建文本。
- 输入源表或结果表DDL语句。
- 单击验证。
- 单击运行。
注册成功的表会出现在Tables列表中,您可以单击表名,查看表的字段和数据类型信息。
- 根据目标Connector语句模板修改定义
- 在左侧导航栏上,单击SQL编辑器。
- 单击Schemas页签。
- 单击Tables旁边的
图标。
- 单击目标Connector。
相关建表语句就会出现在SQL编辑器中。

- 在文本编辑框中,修改Schema和WITH参数。
说明 如果您的SQL需要使用UDF,您需要先注册您的UDF,才能在SQL中使用,注册UDF的操作请参见
管理自定义函数(UDF)。
- 单击验证。
- 单击运行。
注册成功的表会出现在SQL编辑器左侧的Tables列表中,您可以单击表名,查看表的字段和数据类型信息。
- 在Scripts页签,单击新建文本。
- 根据业务逻辑,编写SQL语句。
简单的逻辑为:
INSERT INTO 结果表 SELECT XXX FROM 源表;
说明 您可以为DDL和DML语句分别新建文本框,也可以在源表和结果表DDL定义语句中直接使用CREATE TEMPORARY TABLE关键字,将DDL和DML写在同一个文本,以简化操作。
- 单击保存,输入文本名称后,单击确认。
- 单击验证。
在SQL编辑页面下方,您可以看到SQL语法校验结果,只有通过校验的SQL才能被运行。
- 单击运行。
- 在弹出的对话框中,单击确定。

系统对于含有
INSERT INTO
关键字的DDL文本,会默认创建一个Flink SQL作业。单击
确定后,会自动跳转到作业配置页面。
如果您需要保存SQL文本,您可以单击保存后,在保存的文本中查看已保存的SQL文本。
在文档使用中是否遇到以下问题
更多建议
匿名提交