感谢您的回答，我在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" } 异常信息：Caused by: java.lang.IllegalStateException: No ClusterClientFactory found. If you were targeting a Yarn cluster, please make sure to export the HADOOP_CLASSPATH environment variable or have hadoop in your classpath. For more information refer to the "Deployment & Operations" section of the official Apache Flink documentation. Sebastian Liu <[email protected]> 于2021年1月27日周三 上午1:01写道： > 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 <[email protected]> 于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: [email protected] <[email protected]> > QQ: 3239559* >
