Skip to content

Commit

Permalink
always emmit unexpected blob id error (#2934)
Browse files Browse the repository at this point in the history
Co-authored-by: Navneet Sachan <nsachan@nsachan-mn1.linkedin.biz>
  • Loading branch information
manbearpig1996 and Navneet Sachan authored Nov 7, 2024
1 parent b86d194 commit 2663042
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -1262,9 +1262,9 @@ void processReplicaMetadataResponse(Set<MessageInfo> missingRemoteStoreMessages,
String errorMessage =
String.format("Blob id %s is not in the expected partition Actual partition %s " + " Expected partition %s",
blobId.getID(), blobId.getPartition(), remoteReplicaInfo.getLocalReplicaId().getPartitionId());
replicationMetrics.unexpectedBlobIdError.inc();
if (replicationConfig.replicationIgnoreUnexpectedBlobIdError) {
logger.error(errorMessage);
replicationMetrics.unexpectedBlobIdError.inc();
missingRemoteStoreMessages.remove(messageInfo);
continue;
} else {
Expand Down

0 comments on commit 2663042

Please sign in to comment.