public void testGetSSIThrowsExceptionForCheckpointV1() {
    Checkpoint mockCheckpoint = mock(Checkpoint.class);
    when(mockCheckpoint.getVersion()).thenReturn((short) 1);
    BlobStoreUtil blobStoreUtil =
        new BlobStoreUtil(mock(BlobStoreManager.class), MoreExecutors.newDirectExecutorService(), blobStoreConfig, null, null);
    Map<String, Pair<String, SnapshotIndex>> prevSnapshotIndexes =
        blobStoreUtil.getStoreSnapshotIndexes("testJobName", "testJobId", "taskName",
            mockCheckpoint, new HashSet<>(), false);
    assertEquals(prevSnapshotIndexes.size(), 0);
  }
Tests related to {@link BlobStoreUtil#getStoreSnapshotIndexes}
samza-core/src/test/java/org/apache/samza/storage/blobstore/util/TestBlobStoreUtil.java