private String getPendingProcessorId(ContainerId containerId) {
    for (String pendingProcessorId: state.pendingProcessors.keySet()) {
      YarnContainer yarnContainer = state.pendingProcessors.get(pendingProcessorId);
      if (yarnContainer != null && yarnContainer.id().equals(containerId)) {
        return pendingProcessorId;
      }
    }
    return null;
  }
Returns the Id of the Samza container that corresponds to the provided Yarn {@link ContainerId}
@param containerId the Yarn ContainerId
@return the id of the Samza container corresponding to the {@link ContainerId} that is pending launch
samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java