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

YarnClusterDescriptor.setLocalJarPath介绍

暂无

代码示例

代码示例来源：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

yarnClient,
true)) {
descriptor.setLocalJarPath(new Path("/path/to/flink.jar"));

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

true)) {
yarnClusterDescriptor.setLocalJarPath(new Path(flinkUberjar.getAbsolutePath()));
yarnClusterDescriptor.addShipFiles(Arrays.asList(flinkLibFolder.listFiles()));
yarnClusterDescriptor.addShipFiles(Arrays.asList(flinkShadedHadoopDir.listFiles()));

代码示例来源：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

true);
clusterDescriptor.setLocalJarPath(new Path(flinkJar.getPath()));

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

true);
clusterDescriptor.setLocalJarPath(new Path(flinkUberjar.getAbsolutePath()));
clusterDescriptor.addShipFiles(Arrays.asList(flinkLibFolder.listFiles()));
clusterDescriptor.addShipFiles(Arrays.asList(flinkShadedHadoopDir.listFiles()));