@Test
  public void getActiveTaskChangelogSystemStreamsForActiveAndStandbyContainer() {
    Map<String, SystemStream> expectedStoreToChangelogSystemStreams =
        testContext.storesToSystemStreams;
    Map<String, SystemStream> storeToChangelogSystemStreams = ContainerStorageManagerUtil.getActiveTaskChangelogSystemStreams(
        testContext.storesToSystemStreams, testContext.activeAndStandbyContainerModel);

    assertEquals("Active and standby container model should have non empty store to changelog mapping",
        expectedStoreToChangelogSystemStreams, storeToChangelogSystemStreams);
  }
This test will attempt to verify if logged stores are deleted if the input checkpoints are empty.
samza-core/src/test/scala/org/apache/samza/storage/TestContainerStorageManager.java