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

    assertEquals("Standby container should have no active change log", Collections.emptyMap(),
        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