本文整理了Java中org.apache.flink.yarn.YarnClusterDescriptor.<init>()方法的一些代码示例，展示了YarnClusterDescriptor.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。YarnClusterDescriptor.<init>()方法的具体详情如下：
包路径：org.apache.flink.yarn.YarnClusterDescriptor
类名称：YarnClusterDescriptor
方法名：<init>

YarnClusterDescriptor.<init>介绍

暂无

代码示例

代码示例来源：origin: apache/flink

private AbstractYarnClusterDescriptor getClusterDescriptor(
      Configuration configuration,
      YarnConfiguration yarnConfiguration,
      String configurationDirectory) {
    final YarnClient yarnClient = YarnClient.createYarnClient();
    yarnClient.init(yarnConfiguration);
    yarnClient.start();

    return new YarnClusterDescriptor(
      configuration,
      yarnConfiguration,
      configurationDirectory,
      yarnClient,
      false);
  }
}

代码示例来源：origin: apache/flink

@Nonnull
YarnClusterDescriptor createYarnClusterDescriptor(org.apache.flink.configuration.Configuration flinkConfiguration) {
  final YarnClusterDescriptor yarnClusterDescriptor = new YarnClusterDescriptor(
    flinkConfiguration,
    YARN_CONFIGURATION,
    CliFrontend.getConfigurationDirectoryFromEnv(),
    yarnClient,
    true);
  yarnClusterDescriptor.setLocalJarPath(new Path(flinkUberjar.toURI()));
  yarnClusterDescriptor.addShipFiles(Collections.singletonList(flinkLibFolder));
  return yarnClusterDescriptor;
}

代码示例来源：origin: apache/flink

try (YarnClusterDescriptor descriptor = new YarnClusterDescriptor(
  new Configuration(),
  yarnConfiguration,

代码示例来源：origin: apache/flink

try (YarnClusterDescriptor descriptor = new YarnClusterDescriptor(
  new Configuration(),
  yarnConfiguration,

代码示例来源：origin: apache/flink

YarnClusterDescriptor yarnClusterDescriptor = new YarnClusterDescriptor(
  new Configuration(),
  yarnConfiguration,
closableYarnClient.start();
yarnClusterDescriptor = new YarnClusterDescriptor(
  new Configuration(),
  yarnConfiguration,

代码示例来源：origin: apache/flink

final YarnClient yarnClient = getYarnClient();
try (final YarnClusterDescriptor yarnClusterDescriptor = new YarnClusterDescriptor(
  configuration,
  getYarnConfiguration(),

代码示例来源：origin: apache/flink

@Test
public void testFailIfTaskSlotsHigherThanMaxVcores() throws ClusterDeploymentException {
  final Configuration flinkConfiguration = new Configuration();
  flinkConfiguration.setInteger(ResourceManagerOptions.CONTAINERIZED_HEAP_CUTOFF_MIN, 0);
  YarnClusterDescriptor clusterDescriptor = new YarnClusterDescriptor(
    flinkConfiguration,
    yarnConfiguration,
    temporaryFolder.getRoot().getAbsolutePath(),
    yarnClient,
    true);
  clusterDescriptor.setLocalJarPath(new Path(flinkJar.getPath()));
  ClusterSpecification clusterSpecification = new ClusterSpecification.ClusterSpecificationBuilder()
    .setMasterMemoryMB(1)
    .setTaskManagerMemoryMB(1)
    .setNumberTaskManagers(1)
    .setSlotsPerTaskManager(Integer.MAX_VALUE)
    .createClusterSpecification();
  try {
    clusterDescriptor.deploySessionCluster(clusterSpecification);
    fail("The deploy call should have failed.");
  } catch (ClusterDeploymentException e) {
    // we expect the cause to be an IllegalConfigurationException
    if (!(e.getCause() instanceof IllegalConfigurationException)) {
      throw e;
    }
  } finally {
    clusterDescriptor.close();
  }
}

代码示例来源：origin: apache/flink

configuration.setInteger(ResourceManagerOptions.CONTAINERIZED_HEAP_CUTOFF_MIN, 0);
YarnClusterDescriptor clusterDescriptor = new YarnClusterDescriptor(
  configuration,
  yarnConfiguration,

代码示例来源：origin: apache/flink

final YarnClusterDescriptor clusterDescriptor = new YarnClusterDescriptor(
  configuration,
  yarnConfiguration,

代码示例来源：origin: apache/flink

@Test
public void testSetupApplicationMasterContainer() {
  Configuration cfg = new Configuration();
  YarnClusterDescriptor clusterDescriptor = new YarnClusterDescriptor(
    cfg,
    yarnConfiguration,

代码示例来源：origin: DTStack/flinkStreamSQL

private AbstractYarnClusterDescriptor getClusterDescriptor(
      Configuration configuration,
      YarnConfiguration yarnConfiguration,
      String configurationDirectory) {
    return new YarnClusterDescriptor(
        configuration,
        yarnConfiguration,
        configurationDirectory,
        yarnClient,
        false);
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn_2.11

private AbstractYarnClusterDescriptor getClusterDescriptor(
      Configuration configuration,
      YarnConfiguration yarnConfiguration,
      String configurationDirectory) {
    final YarnClient yarnClient = YarnClient.createYarnClient();
    yarnClient.init(yarnConfiguration);
    yarnClient.start();

    return new YarnClusterDescriptor(
      configuration,
      yarnConfiguration,
      configurationDirectory,
      yarnClient,
      false);
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn

private AbstractYarnClusterDescriptor getClusterDescriptor(
      Configuration configuration,
      YarnConfiguration yarnConfiguration,
      String configurationDirectory) {
    final YarnClient yarnClient = YarnClient.createYarnClient();
    yarnClient.init(yarnConfiguration);
    yarnClient.start();

    return new YarnClusterDescriptor(
      configuration,
      yarnConfiguration,
      configurationDirectory,
      yarnClient,
      false);
  }
}

代码示例来源：origin: DTStack/flinkStreamSQL

AbstractYarnClusterDescriptor clusterDescriptor = new YarnClusterDescriptor(config, yarnConf, ".", yarnClient, false);
ClusterClient clusterClient = clusterDescriptor.retrieve(applicationId);
clusterClient.setDetached(true);