private ServerErrorCode repairTombStoneToLocalStore(ReplicateBlobRequest replicateBlobRequest, BlobId blobId) {
    Store store = storeManager.getStore(blobId.getPartition());
    ServerErrorCode errorCode = ServerErrorCode.NoError;

    try {
      metrics.replicateDeleteRecordRate.mark();
      // Force write tombstone with lifeVersion = 0.
      MessageInfo deleteRecord = new MessageInfo.Builder(blobId, -1, blobId.getAccountId(), blobId.getContainerId(),
          replicateBlobRequest.getOperationTimeInMs()).isDeleted(true).lifeVersion((short) 0).build();
      store.forceDelete(Collections.singletonList(deleteRecord));
      logger.info("ReplicateBlobRequest repair tombstone {} : {}", blobId, deleteRecord);
    } catch (StoreException e) { // catch the store write exception
      // if forceDelete fail due to local store has the key, it throws Already_Exist exception.
      // Let it fail and retry will go with the regular delete.
      // LOCAL_CONSISTENCY_TODO: add a concurrent test to verify the Already_Exist case
      errorCode = ErrorMapping.getStoreErrorMapping(e.getErrorCode());
      if (e.getErrorCode() == StoreErrorCodes.AlreadyExist) {
        logger.error("ReplicateBlobRequest Blob {} already exists for {}", blobId, replicateBlobRequest);
      } else {
        logger.error("ReplicateBlobRequest unknown exception to replicate {} of {}", blobId, replicateBlobRequest, e);
      }
    }

    return errorCode;
  }
Get the Blob from the remote replica
@param replicateBlobRequest the {@link ReplicateBlobRequest}
@return a pair of the {@link ServerErrorCode} and the {@link GetResponse}.
ambry-server/src/main/java/com/github/ambry/server/AmbryRequests.java