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

前提条件

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

• 项目负责人或项目管理员（Project_Admin）已经在项目内创建好 Flink 资源池，请参见创建通用-VCI 资源池。
• 需要创建 Session 集群（当期仅支持 Flink 1.17 版本），并启动运行。请参见 创建 Session 集群。
• 一般是由开发人员（Project_Dev） 负责开发任务，请确保操作员已被添加为项目成员并为其关联角色，请参见添加项目成员。
• 当前临时查询仅限制使用部分 DQL 语句。更多 DML/DDL 后续版本即将支持。

开发 Flink SQL 查询任务

1. 登录流式计算 Flink 版控制台。
2. 在顶部菜单栏选择目标地域。
3. 在左侧导航栏选择项目管理，在搜索框中根据项目名称进行模糊搜索，然后单击项目区块进入项目。
4. 在项目左侧导航栏选择数据查询。
5. 在数据查询页面单击加号按钮，创建任务。
   您也可以选择目标文件夹，直接在该文件夹中创建任务。


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


| | | \

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

6. 在任务上部区域，选择运行中的 Session 集群。如果没有运行中的 Session 集群请参考 创建 Session 集群 创建并且启动一个。


7. 在任务编辑区编辑 SQL 任务的业务逻辑代码。
   任务创建完后默认打开任务的代码编辑区，您可根据实际业务编写 SQL 代码。
   此处提供一个测试用例，可将其中 catalog 、db、table 等替换成实际生产内容。

   select
     now(), *
   from
     `<your_catalog>`.`<your_database>`.`<your_table>`
   limit
     10;
   

8. 或者可以从数据目录 Tab 复制表名称，可以方便的生成查询目标：


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


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 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 需求。