更新时间:2025-07-14 GMT+08:00
配置Flink SQL Client支持SQL校验功能
本章节适用于MRS 3.3.0及以后版本。
配置Flink SQL Client支持SQL校验功能方法
通过SQL Client进行SQL作业开发时,支持进入校验模式校验SQL语法正确性。校验模式下执行SQL命令不会启动Flink job。
- 校验SQL语句
- 执行SQL shell命令时添加“-v”参数(或“--validate”参数)直接进入校验模式。
sql-client.sh -v
- 执行SQL shell命令时通过SET命令进入或退出校验模式。
- 进入校验模式:
SET table.validate = true;
- 退出校验模式:
SET table.validate = false;
- 进入校验模式:
- 执行SQL shell命令时添加“-v”参数(或“--validate”参数)直接进入校验模式。
使用FlinkSQL Client提交作业
- 安装集群客户端,例如安装目录为“/opt/hadoopclient”。
- 以客户端安装用户,登录安装客户端的节点。
- 执行以下命令,切换到客户端安装目录。
cd /opt/hadoopclient
- 执行如下命令初始化环境变量。
source /opt/hadoopclient/bigdata_env
- 进入FlinkSQL Client并提交作业。
- 参考Flink客户端使用实践启动yarn-session,并记录yarn-session ID(yid)。
yarn-session.sh -nm "session-name"
- 执行以下命令进入FlinkSQL Client。
cd /opt/hadoopclient/Flink/flink/bin
./sql-client.sh
图1 进入FlinkSQL Client - 设置“high-availability.cluster-id”为yarn-session ID。
SET high-availability.cluster-id=yarn-session ID;
- 参考Flink客户端使用实践启动yarn-session,并记录yarn-session ID(yid)。
父主题: Flink企业级能力增强