好的
Lin Li 于2021年1月27日周三 下午5:20写道：
> try: "execution.target: yarn-pre-job" -> "execution.target:
> yarn-per-job"
>
> zilong xiao 于2021年1月27日周三 上午10:17写道：
>
> > 感谢您的回答，我在flink-conf.yaml里指定"execution.target: yarn-pre-job"后，尝试用rest
> > api生成session id时会遇到异常，不清楚是为何，可否帮忙看下
> >
> > flink version:
try: "execution.target: yarn-pre-job" -> "execution.target: yarn-per-job"
zilong xiao 于2021年1月27日周三 上午10:17写道：
> 感谢您的回答，我在flink-conf.yaml里指定"execution.target: yarn-pre-job"后，尝试用rest
> api生成session id时会遇到异常，不清楚是为何，可否帮忙看下
>
> flink version: 1.11.3
> execution.target: yarn-pre-job
> rest
看报错提示，应该是没有指定正确HADOOP_HOME env? 如果用flink client提交，也是需要这个env的
zilong xiao 于2021年1月27日周三 上午10:17写道：
> 感谢您的回答，我在flink-conf.yaml里指定"execution.target: yarn-pre-job"后，尝试用rest
> api生成session id时会遇到异常，不清楚是为何，可否帮忙看下
>
> flink version: 1.11.3
> execution.target: yarn-pre-job
> rest api请求路径和参数：
>
感谢您的回答，我在flink-conf.yaml里指定"execution.target: yarn-pre-job"后，尝试用rest
api生成session id时会遇到异常，不清楚是为何，可否帮忙看下
flink version: 1.11.3
execution.target: yarn-pre-job
rest api请求路径和参数：
http://localhost:8083/v1/sessions
{
"planner": "blink",
"execution_type": "streaming"
}
sql gateway 提交job方式和flink client类似主要取决于flink-conf中的execution.config 配置,
对per job模式on yarn, 对应的配置是“yarn-per-job”,
这样加载的PipelineExecutor会控制为：YarnJobClusterExecutorFactory，具备向Yarn提交job的能力，这和使用flink
client
提交job最终是一个调用路径，余下在flink-conf中添加上yarn相关配置我理解就可以了。
请问有关于flink-sql-gateway rest api以pre job模式提交作业到yarn集群的文档吗？
