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

YarnResourceManager.requestYarnContainer介绍

[英]Request new container if pending containers cannot satisfies pending slot requests.
[中]

代码示例

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

/**
 * Request new container if pending containers cannot satisfies pending slot requests.
 */
private void requestYarnContainerIfRequired() {
  int requiredTaskManagerSlots = getNumberRequiredTaskManagerSlots();
  int pendingTaskManagerSlots = numPendingContainerRequests * numberOfTaskSlots;
  if (requiredTaskManagerSlots > pendingTaskManagerSlots) {
    requestYarnContainer();
  }
}

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

@Override
public Collection<ResourceProfile> startNewWorker(ResourceProfile resourceProfile) {
  Preconditions.checkArgument(
    ResourceProfile.UNKNOWN.equals(resourceProfile),
    "The YarnResourceManager does not support custom ResourceProfiles yet. It assumes that all containers have the same resources.");
  requestYarnContainer();
  return slotsPerWorker;
}

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

/**
 * Request new container if pending containers cannot satisfies pending slot requests.
 */
private void requestYarnContainerIfRequired(Resource resource, Priority priority) {
  int requiredTaskManagerSlots = getNumberRequiredTaskManagerSlots();
  int pendingTaskManagerSlots = numPendingContainerRequests * numberOfTaskSlots;
  if (requiredTaskManagerSlots > pendingTaskManagerSlots) {
    requestYarnContainer(resource, priority);
  }
}

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

/**
 * Request new container if pending containers cannot satisfies pending slot requests.
 */
private void requestYarnContainerIfRequired() {
  int requiredTaskManagerSlots = getNumberRequiredTaskManagerSlots();
  int pendingTaskManagerSlots = numPendingContainerRequests * numberOfTaskSlots;
  if (requiredTaskManagerSlots > pendingTaskManagerSlots) {
    requestYarnContainer();
  }
}

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

@Override
public Collection<ResourceProfile> startNewWorker(ResourceProfile resourceProfile) {
  Preconditions.checkArgument(
    ResourceProfile.UNKNOWN.equals(resourceProfile),
    "The YarnResourceManager does not support custom ResourceProfiles yet. It assumes that all containers have the same resources.");
  requestYarnContainer();
  return slotsPerWorker;
}

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

@Override
public Collection<ResourceProfile> startNewWorker(ResourceProfile resourceProfile) {
  // Priority for worker containers - priorities are intra-application
  //TODO: set priority according to the resource allocated
  Priority priority = Priority.newInstance(generatePriority(resourceProfile));
  int mem = resourceProfile.getMemoryInMB() < 0 ? defaultTaskManagerMemoryMB : resourceProfile.getMemoryInMB();
  int vcore = resourceProfile.getCpuCores() < 1 ? defaultCpus : (int) resourceProfile.getCpuCores();
  Resource capability = Resource.newInstance(mem, vcore);
  requestYarnContainer(capability, priority);
  return slotsPerWorker;
}