@Override
      public void run() {
        assertEquals(requestState.numPendingRequests(), 0);
      }
Handles expired requests correctly and assigns ANY_HOST
samza-core/src/test/java/org/apache/samza/clustermanager/TestContainerAllocatorWithHostAffinity.java