好的😓 Lin Li <[email protected]> 于2021年1月27日周三 下午5:20写道：
> try: "execution.target: yarn-pre-job" -> "execution.target: > yarn-per-job" > > zilong xiao <[email protected]> 于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请求路径和参数： > > 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* > > > > > >
