try: "execution.target: yarn-pre-job" -> "execution.target: yarn-per-job"
zilong xiao <acidzz...@gmail.com> 于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 <liuyang0...@gmail.com> 于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 <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* > > >
