临时查询（Beta）--流式计算 Flink版-火山引擎

文档中心

立即注册

流式计算 Flink版

临时查询

临时查询（Beta）

在 Flink 控制台，您可以创建 Flink SQL 数据查询，通过简单的 SQL 语句表达您的业务逻辑，能够实现对外部数据，如数据湖等进行数据探索，也能够高效的完成一些调试和验证工作。

前提条件

您在开始开发 SQL 临时查询前，应提前完成以下准备工作：

项目负责人或项目管理员（Project_Admin）已经在项目内创建好 Flink 资源池，请参见创建通用-VCI 资源池。
需要创建 Session 集群（当期仅支持 Flink 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 语句，使得语句更加美观、整洁、可读。
代码编辑和验证通过后，单击保存按钮，保存任务代码。查询结果示意如下

SQL 语法支持清单

当前临时查询支持语法包括如下：

类型	是否支持	语法	说明
CREATE Statements	✅	CREATE TABLE	创建数据表
	✅	CREATE CATALOG	创建 Catalog
	✅	CREATE DATABASE	创建 Database
DROP Statements （风险操作，屏蔽）	❌	DROP CATALOG	暂不支持 Drop 相关命令
	❌	DROP TABLE
	❌	DROP DATABASE
	❌	DROP VIEW
	❌	DROP FUNCTION
ALTER Statements	✅	ALTER TABLE	修改表设置
ALTER Statements	✅	ALTER DATABASE	修改数据库设置
SHOW Statements	✅	SHOW CATALOGS	列举数据目录
	✅	SHOW DATABASES	列举数据库
	✅	SHOW TABLES	列举数据表
	✅	SHOW CREATE TABLE	查询建表语句
	✅	SHOW COLUMNS	查询表数据列
DESCRIBE Statements	✅	DESCRIBE TABLE	DESCRIBE 数据表
Queries	✅	SELECT	支持查询包括： Hints WITH clause SELECT & WHERE SELECT DISTINCT Windowing TVF Window Aggregation Group Aggregation Over Aggregation Joins Window JOIN Set Operations ORDER BY clause LIMIT clause Top-N Window Top-N Deduplication Window Deduplication Pattern Recognition
INSERT Statements	✅	INSERT	INSERT 插入语句
SET Statements	✅	SET	SET 设置参数注意：部分参数在临时查询设置没有实际效果。

常见问题

问题：查询报错 Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/hadoop/conf/Configuration
原因：Session 集群版本过老，需要重启以使用最新版本 Flink 功能。
解决方案：重启 Session 集群，并重新进行临时查询。

问题：查询报错 unsupported sql statement type, sql: ...;
原因：当前版本暂不支持此类 SQL 。
解决方案：等待后续版本持续扩容支持 SQL。或者通过提交工单（参考技术支持）来反馈您的 SQL 需求。

最近更新时间：2025.12.29 11:42:32

这个页面对您有帮助吗？

有用

无用

流式计算 Flink版

前提条件 #

开发 Flink SQL 查询任务 #

SQL 语法支持清单 #

常见问题 #

前提条件

开发 Flink SQL 查询任务

SQL 语法支持清单

常见问题