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

YarnContainerInLaunch介绍

[英]This class describes a container in which a TaskManager is being launched (or has been launched) but where the TaskManager has not properly registered, yet.
[中]此类描述了一个容器，其中TaskManager正在启动（或已启动），但TaskManager尚未正确注册。

代码示例

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

YarnContainerInLaunch containerInLaunch = new YarnContainerInLaunch(c, now);
containersInLaunch.put(containerInLaunch.getResourceID(), containerInLaunch);

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

final YarnContainerInLaunch containerInLaunch = new YarnContainerInLaunch(container);
final ResourceID resourceID = containerInLaunch.getResourceID();
containersInLaunch.put(resourceID, containerInLaunch);

代码示例来源：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: org.apache.flink/flink-yarn_2.11

YarnContainerInLaunch containerInLaunch = new YarnContainerInLaunch(c, now);
containersInLaunch.put(containerInLaunch.getResourceID(), containerInLaunch);

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

YarnContainerInLaunch containerInLaunch = new YarnContainerInLaunch(c, now);
containersInLaunch.put(containerInLaunch.getResourceID(), containerInLaunch);

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

final YarnContainerInLaunch containerInLaunch = new YarnContainerInLaunch(container);
final ResourceID resourceID = containerInLaunch.getResourceID();
containersInLaunch.put(resourceID, containerInLaunch);

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

final YarnContainerInLaunch containerInLaunch = new YarnContainerInLaunch(container);
final ResourceID resourceID = containerInLaunch.getResourceID();
containersInLaunch.put(resourceID, containerInLaunch);

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

@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 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;
}