[
https://issues.apache.org/jira/browse/FLINK-33423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhengzhili updated FLINK-33423:
-------------------------------
Description:
YarnClusterClientFactory. GetClusterDescriptor method Unable to load the
configuration for yarn . The reason is that it is called
HadoopUtils.getHadoopConfiguration and this method only loading HDFS
configuration.
{quote}private YarnClusterDescriptor getClusterDescriptor(Configuration
configuration) {
final YarnClient yarnClient = YarnClient.createYarnClient();
final YarnConfiguration yarnConfiguration =
Utils.getYarnAndHadoopConfiguration(configuration);
yarnClient.init(yarnConfiguration);
yarnClient.start();
return new YarnClusterDescriptor(
configuration,
yarnConfiguration,
yarnClient,
YarnClientYarnClusterInformationRetriever.create(yarnClient),
false);
}{quote}
was:YarnClusterClientFactory. GetClusterDescriptor method Unable to load
the configuration for yarn . The reason is that it is called
HadoopUtils.getHadoopConfiguration and this method only loading HDFS
configuration.
> Resolve the problem that yarnClient cannot load yarn configurations
> -------------------------------------------------------------------
>
> Key: FLINK-33423
> URL: https://issues.apache.org/jira/browse/FLINK-33423
> Project: Flink
> Issue Type: Bug
> Components: Client / Job Submission
> Reporter: zhengzhili
> Priority: Major
> Attachments: 微信图片_20231101151644.png, 微信图片_20231101152359.png,
> 微信图片_20231101152404.png, 微信截图_20231101152725.png
>
>
> YarnClusterClientFactory. GetClusterDescriptor method Unable to load the
> configuration for yarn . The reason is that it is called
> HadoopUtils.getHadoopConfiguration and this method only loading HDFS
> configuration.
> {quote}private YarnClusterDescriptor getClusterDescriptor(Configuration
> configuration) {
> final YarnClient yarnClient = YarnClient.createYarnClient();
> final YarnConfiguration yarnConfiguration =
> Utils.getYarnAndHadoopConfiguration(configuration);
> yarnClient.init(yarnConfiguration);
> yarnClient.start();
> return new YarnClusterDescriptor(
> configuration,
> yarnConfiguration,
> yarnClient,
> YarnClientYarnClusterInformationRetriever.create(yarnClient),
> false);
> }{quote}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
