Add warn logs for remote backpressure rejection (#13218)

Signed-off-by: Gaurav Bafna <[email protected]>
opensearch-project · Apr 16, 2024 · 8bd0ad9 · 8bd0ad9
1 parent a2f07ed
commit 8bd0ad9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/server/src/main/java/org/opensearch/index/remote/RemoteStorePressureService.java b/server/src/main/java/org/opensearch/index/remote/RemoteStorePressureService.java
@@ -78,7 +78,9 @@ public void validateSegmentsUploadLag(ShardId shardId) {
         for (LagValidator lagValidator : lagValidators) {
             if (lagValidator.validate(remoteSegmentTransferTracker, shardId) == false) {
                 remoteSegmentTransferTracker.incrementRejectionCount(lagValidator.name());
-                throw new OpenSearchRejectedExecutionException(lagValidator.rejectionMessage(remoteSegmentTransferTracker, shardId));
+                String rejectionMessage = lagValidator.rejectionMessage(remoteSegmentTransferTracker, shardId);
+                logger.warn("Rejecting write requests for shard due to remote backpressure:  {}", rejectionMessage);
+                throw new OpenSearchRejectedExecutionException(rejectionMessage);
             }
         }
     }