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

YarnContainerInLaunch.container介绍

暂无

代码示例

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

@Override
protected void releasePendingWorker(ResourceID id) {
  YarnContainerInLaunch container = containersInLaunch.remove(id);
  if (container != null) {
    releaseYarnContainer(container.container());
  } else {
    LOG.error("Cannot find container {} to release. Ignoring request.", id);
  }
}

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

@Override
protected RegisteredYarnWorkerNode workerStarted(ResourceID resourceID) {
  YarnContainerInLaunch inLaunch = containersInLaunch.remove(resourceID);
  if (inLaunch == null) {
    // Container was not in state "being launched", this can indicate that the TaskManager
    // in this container was already registered or that the container was not started
    // by this resource manager. Simply ignore this resourceID.
    return null;
  } else {
    return new RegisteredYarnWorkerNode(inLaunch.container());
  }
}

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

@Override
protected Collection<RegisteredYarnWorkerNode> reacceptRegisteredWorkers(Collection<ResourceID> toConsolidate) {
  // we check for each task manager if we recognize its container
  List<RegisteredYarnWorkerNode> accepted = new ArrayList<>();
  for (ResourceID resourceID : toConsolidate) {
    YarnContainerInLaunch yci = containersInLaunch.remove(resourceID);
    if (yci != null) {
      LOG.info("YARN container consolidation recognizes Resource {} ", resourceID);
      accepted.add(new RegisteredYarnWorkerNode(yci.container()));
    }
    else {
      if (isStarted(resourceID)) {
        LOG.info("TaskManager {} has already been registered at the resource manager.", resourceID);
      } else {
        LOG.info("YARN container consolidation does not recognize TaskManager {}",
          resourceID);
      }
    }
  }
  return accepted;
}

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

@Override
protected void releasePendingWorker(ResourceID id) {
  YarnContainerInLaunch container = containersInLaunch.remove(id);
  if (container != null) {
    releaseYarnContainer(container.container());
  } else {
    LOG.error("Cannot find container {} to release. Ignoring request.", id);
  }
}

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

@Override
protected RegisteredYarnWorkerNode workerStarted(ResourceID resourceID) {
  YarnContainerInLaunch inLaunch = containersInLaunch.remove(resourceID);
  if (inLaunch == null) {
    // Container was not in state "being launched", this can indicate that the TaskManager
    // in this container was already registered or that the container was not started
    // by this resource manager. Simply ignore this resourceID.
    return null;
  } else {
    return new RegisteredYarnWorkerNode(inLaunch.container());
  }
}

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

@Override
protected RegisteredYarnWorkerNode workerStarted(ResourceID resourceID) {
  YarnContainerInLaunch inLaunch = containersInLaunch.remove(resourceID);
  if (inLaunch == null) {
    // Container was not in state "being launched", this can indicate that the TaskManager
    // in this container was already registered or that the container was not started
    // by this resource manager. Simply ignore this resourceID.
    return null;
  } else {
    return new RegisteredYarnWorkerNode(inLaunch.container());
  }
}

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

@Override
protected void releasePendingWorker(ResourceID id) {
  YarnContainerInLaunch container = containersInLaunch.remove(id);
  if (container != null) {
    releaseYarnContainer(container.container());
  } else {
    LOG.error("Cannot find container {} to release. Ignoring request.", id);
  }
}

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

@Override
protected Collection<RegisteredYarnWorkerNode> reacceptRegisteredWorkers(Collection<ResourceID> toConsolidate) {
  // we check for each task manager if we recognize its container
  List<RegisteredYarnWorkerNode> accepted = new ArrayList<>();
  for (ResourceID resourceID : toConsolidate) {
    YarnContainerInLaunch yci = containersInLaunch.remove(resourceID);
    if (yci != null) {
      LOG.info("YARN container consolidation recognizes Resource {} ", resourceID);
      accepted.add(new RegisteredYarnWorkerNode(yci.container()));
    }
    else {
      if (isStarted(resourceID)) {
        LOG.info("TaskManager {} has already been registered at the resource manager.", resourceID);
      } else {
        LOG.info("YARN container consolidation does not recognize TaskManager {}",
          resourceID);
      }
    }
  }
  return accepted;
}

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

@Override
protected Collection<RegisteredYarnWorkerNode> reacceptRegisteredWorkers(Collection<ResourceID> toConsolidate) {
  // we check for each task manager if we recognize its container
  List<RegisteredYarnWorkerNode> accepted = new ArrayList<>();
  for (ResourceID resourceID : toConsolidate) {
    YarnContainerInLaunch yci = containersInLaunch.remove(resourceID);
    if (yci != null) {
      LOG.info("YARN container consolidation recognizes Resource {} ", resourceID);
      accepted.add(new RegisteredYarnWorkerNode(yci.container()));
    }
    else {
      if (isStarted(resourceID)) {
        LOG.info("TaskManager {} has already been registered at the resource manager.", resourceID);
      } else {
        LOG.info("YARN container consolidation does not recognize TaskManager {}",
          resourceID);
      }
    }
  }
  return accepted;
}