游客xe6esyht7obhq_个人页

个人头像照片 游客xe6esyht7obhq
个人头像照片
0
1
0

个人介绍

暂无个人介绍

擅长的技术

  • Java
  • Python
获得更多能力
通用技术能力:

暂时未有相关通用技术能力~

云产品技术能力:

暂时未有相关云产品技术能力~

阿里云技能认证

详细说明
暂无更多信息
暂无更多信息
正在加载, 请稍后...
暂无更多信息
  • 回答了问题 2021-11-04

    请问一下各位大佬,java 写的flink程序提交到yarn集群,application name都

    flink1.13.3源码: flink-yarn项目下的YarnClusterDescriptor类 session pre-job yarn-application yarn的名称写死了。除非自己改源码编译jar包。 -ynm参数是无效的。我也烦死了。启动很多yarn,完全不知道那个是那个。 为啥不用application-type来区分 三种启动模式。太无语了。 package org.apache.flink.yarn; @Override public ClusterClientProvider deployApplicationCluster( final ClusterSpecification clusterSpecification, final ApplicationConfiguration applicationConfiguration) throws ClusterDeploymentException { checkNotNull(clusterSpecification); checkNotNull(applicationConfiguration); final YarnDeploymentTarget deploymentTarget = YarnDeploymentTarget.fromConfig(flinkConfiguration); if (YarnDeploymentTarget.APPLICATION != deploymentTarget) { throw new ClusterDeploymentException( 'Couldn't deploy Yarn Application Cluster.' + ' Expected deployment.target=' + YarnDeploymentTarget.APPLICATION.getName() + ' but actual one was \'' + deploymentTarget.getName() + '\''); } applicationConfiguration.applyToConfiguration(flinkConfiguration); final List pipelineJars = flinkConfiguration .getOptional(PipelineOptions.JARS) .orElse(Collections.emptyList()); Preconditions.checkArgument(pipelineJars.size() == 1, 'Should only have one jar'); try { return deployInternal( clusterSpecification, 'Flink Application Cluster', YarnApplicationClusterEntryPoint.class.getName(), null, false); } catch (Exception e) { throw new ClusterDeploymentException('Couldn't deploy Yarn Application Cluster', e); } } @Override public ClusterClientProvider deploySessionCluster( ClusterSpecification clusterSpecification) throws ClusterDeploymentException { try { return deployInternal( clusterSpecification, 'Flink session cluster', getYarnSessionClusterEntrypoint(), null, false); } catch (Exception e) { throw new ClusterDeploymentException('Couldn't deploy Yarn session cluster', e); } } @Override public ClusterClientProvider deployJobCluster( ClusterSpecification clusterSpecification, JobGraph jobGraph, boolean detached) throws ClusterDeploymentException { try { return deployInternal( clusterSpecification, 'Flink per-job cluster', getYarnJobClusterEntrypoint(), jobGraph, detached); } catch (Exception e) { throw new ClusterDeploymentException('Could not deploy Yarn job cluster.', e); } }
    踩0 评论0
正在加载, 请稍后...
滑动查看更多
正在加载, 请稍后...
暂无更多信息