本文为您介绍实时计算Flink版作业开发流程以及语法检查、配置作业参数、配置项目参数、SQL辅助和SQL版本管理功能。
背景信息
说明
- 实时计算Flink版主要使用Flink SQL进行作业开发,Flink SQL开发手册请参见概述。
- 实时计算Flink版独享模式不支持归档保存已停止(含暂停)的作业运行日志。如果您需要查询已停止(含暂停)的作业运行日志,请将日志输出至您自定义的日志服务SLS或对象存储OSS中。详情请参见自定义日志级别和下载路径。
编写SQL代码
配置作业参数
配置项目参数
作业参数针对单个作业生效,项目参数针对该项目下所有作业生效,开启项目参数后,会产生以下两种效果:
- 替换变量:单击启动、调试或语法检查后,系统会替换SQL作业中的变量或Datastream作业中代码的变量。
- 参数下发:项目级别系统参数会与作业参数、启动参数(仅Batch作业可以配置)进行Merge,参数优先级为:启动参数 > 作业参数 > 项目级别系统参数。Merge后作为最终参数下发到Blink作业。例如,作业参数配置和项目参数配置冲突,系统则以作业参数配置为准。
启动语法检查
SQL辅助
- Flink SQL语法检查
在您修改SQL后即可自动保存。保存操作可以触发SQL语法检查功能。语法校验出错后,将在作业开发页面提示出错行数、列数以及错误原因。
- Flink SQL智能提示
在您输入Flink SQL过程中,作业开发页面提供包括关键字、内置函数、表和字段智能记忆等提示功能。
- Flink SQL语法高亮显示
高亮显示Flink SQL中关键字,使用不同的颜色区分Flink SQL语法中不同的结构。
SQL版本管理
实时计算Flink版为您提供代码版本管理功能。每提交一次作业即可生成一个代码版本。代码版本用于版本追踪、版本修改以及后期版本回滚。