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相关配置我理解就可以了。 org.apache.flink.yarn.configuration.YarnConfigOptions
zilong xiao <acidzz...@gmail.com> 于2021年1月26日周二 下午4:00写道： > 请问有关于flink-sql-gateway rest api以pre job模式提交作业到yarn集群的文档吗？ > -- *With kind regards ------------------------------------------------------------ Sebastian Liu 刘洋 Institute of Computing Technology, Chinese Academy of Science Mobile\WeChat: +86—15201613655 E-mail: liuyang0...@gmail.com <liuyang0...@gmail.com> QQ: 3239559*
