Add warn logs for remote backpressure rejection (#13218) (#13228)

opensearch-trigger-bot[bot] · github-actions[bot] · web-flow · commit a3125a9e1cff · 2024-04-16T12:58:31.000-04:00
(cherry picked from commit 8bd0ad9) Signed-off-by: Gaurav Bafna <gbbafna@amazon.com> Signed-off-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com> Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
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);
             }
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -78,7 +78,9 @@ public void validateSegmentsUploadLag(ShardId shardId) {`
`78`	`78`	`for (LagValidator lagValidator : lagValidators) {`
`79`	`79`	`if (lagValidator.validate(remoteSegmentTransferTracker, shardId) == false) {`
`80`	`80`	`remoteSegmentTransferTracker.incrementRejectionCount(lagValidator.name());`
`81`		`- throw new OpenSearchRejectedExecutionException(lagValidator.rejectionMessage(remoteSegmentTransferTracker, shardId));`
	`81`	`+ String rejectionMessage = lagValidator.rejectionMessage(remoteSegmentTransferTracker, shardId);`
	`82`	`+ logger.warn("Rejecting write requests for shard due to remote backpressure: {}", rejectionMessage);`
	`83`	`+ throw new OpenSearchRejectedExecutionException(rejectionMessage);`
`82`	`84`	`}`
`83`	`85`	`}`
`84`	`86`	`}`