在 Flink 控制台,您可以创建 Flink SQL 数据查询,通过简单的 SQL 语句表达您的业务逻辑,能够实现对外部数据,如数据湖等进行数据探索,也能够高效的完成一些调试和验证工作。
前提条件
您在开始开发 SQL 临时查询前,应提前完成以下准备工作:
- 项目负责人或项目管理员(Project_Admin)已经在项目内创建好 Flink 资源池,请参见创建通用-VCI 资源池。
- 需要创建 Session 集群(当期仅支持 1.17 版本以上),并启动运行。请参见 创建 Session 集群。
- 一般是由开发人员(Project_Dev) 负责开发任务,请确保操作员已被添加为项目成员并为其关联角色,请参见添加项目成员。
- 当前临时查询仅限制使用部分 DQL 语句。更多 DML/DDL 后续版本即将支持。
开发 Flink SQL 查询任务
- 登录流式计算 Flink 版控制台。
- 在顶部菜单栏选择目标地域。
- 在左侧导航栏选择项目管理,在搜索框中根据项目名称进行模糊搜索,然后单击项目区块进入项目。
- 在项目左侧导航栏选择数据查询。
- 在数据查询页面单击加号按钮,创建任务。
您也可以选择目标文件夹,直接在该文件夹中创建任务。

- 在创建作业对话框,设置脚本名称、所属文件夹等参数,然后单击确定。

配置 | 说明 |
|---|
任务名称 | 自定义设置任务的名称。
名称的字符长度限制在 1~48,支持数字、大小写英文字母、下划线(_)、短横线(-)和英文句号(.),且首尾只能是数字或字母。 |
所属文件夹 | 从下拉列表中选择目标文件夹。
系统默认存在一个数据开发文件夹,但为了更方便的管理任务,您可以自由创建文件夹。
如何创建文件夹,请参见管理任务文件夹。 |
- 在任务上部区域,选择运行中的 Session 集群。如果没有运行中的 Session 集群请参考 创建 Session 集群 创建并且启动一个。

在任务编辑区编辑 SQL 任务的业务逻辑代码。
任务创建完后默认打开任务的代码编辑区,您可根据实际业务编写 SQL 代码。
此处提供一个测试用例,可将其中 catalog 、db、table 等替换成实际生产内容。
select
now(), *
from
`<your_catalog>`.`<your_database>`.`<your_table>`
limit
10;
或者可以从数据目录 Tab 复制表名称,可以方便的生成查询目标:

- 单击格式化按钮,系统自动调整SQL代码格式。
系统将自动美化您的 SQL 语句,使得语句更加美观、整洁、可读。 - 代码编辑和验证通过后,单击保存按钮,保存任务代码。查询结果示意如下
