code: private void updateKeySetForBlobStore(Set<String> keySetBlobStore, CuratorFramework zkClient) {
          try {
              for (String key : keySetBlobStore) {
                  LOG.debug("updating blob");
                  BlobStoreUtils.updateKeyForBlobStore(conf, blobStore, zkClient, key, nimbusInfo);
              }
          } catch (Exception exp) {
              throw new RuntimeException(exp);
          }
      }
docs: Update current key list inside the blobstore if the version changes