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 ) ; } }
Update current key list inside the blobstore if the version changes