@Test
  public void testDelayedRequestedContainers() {
    containerAllocator.requestResource("0", "abc");
    containerAllocator.requestResourceWithDelay("0", "efg", Duration.ofHours(2));
    containerAllocator.requestResourceWithDelay("0", "hij", Duration.ofHours(3));
    containerAllocator.requestResourceWithDelay("0", "klm", Duration.ofHours(4));

    assertNotNull(clusterResourceManager.resourceRequests);
    assertEquals(clusterResourceManager.resourceRequests.size(), 1);
    assertEquals(requestState.numPendingRequests(), 1);
    assertEquals(requestState.numDelayedRequests(), 3);
  }
Test that extra resources are buffered under ANY_HOST
samza-core/src/test/java/org/apache/samza/clustermanager/TestContainerAllocatorWithHostAffinity.java