Cosmos: Fix 410/1002 PartitionKeyRangeGone surfacing on query path during split/merge

The query-path PartitionKeyRangeGoneRetryPolicy retried 410/1002 only once and ignored 410/1007 (CompletingSplitOrMerge) and 410/1008 (CompletingPartitionMigration), surfacing transient 410s to query callers during a partition split/merge. It now refreshes the routing map and retries those sub-statuses up to 10 times (using an AtomicInteger counter), matching the bulk/transactional-batch retry policies. Mirrors the .NET SDK fix (Azure/azure-cosmos-dotnet-v3 PR #5941).

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

Author: Copilot

sdk/cosmos/azure-cosmos/CHANGELOG.md

@@ -7,6 +7,7 @@
 #### Breaking Changes
 
 #### Bugs Fixed
+* Fixed transient `410/1002` (`PartitionKeyRangeGone`) errors surfacing to query callers during a partition split or merge. The query-path `PartitionKeyRangeGoneRetryPolicy` previously retried only once and ignored the in-progress `410/1007` (`CompletingSplitOrMerge`) and `410/1008` (`CompletingPartitionMigration`) sub-status codes; it now refreshes the routing map and retries those sub-statuses up to 10 times before surfacing the error.
 
 #### Other Changes
 

sdk/cosmos/azure-cosmos/src/main/java/com/azure/cosmos/implementation/PartitionKeyRangeGoneRetryPolicy.java

@@ -11,6 +11,7 @@
 
 import java.time.Duration;
 import java.util.Map;
+import java.util.concurrent.atomic.AtomicInteger;
 
 // TODO: this need testing
 /**
@@ -25,7 +26,8 @@ public class PartitionKeyRangeGoneRetryPolicy extends DocumentClientRetryPolicy
     private final IPartitionKeyRangeCache partitionKeyRangeCache;
     private final String collectionLink;
     private final Map<String, Object> requestOptionProperties;
-    private volatile boolean retried;
+    private static final int MAX_RETRY_COUNT = 10;
+    private final AtomicInteger retryCount = new AtomicInteger(0);
     private RxDocumentServiceRequest request;
 
     public PartitionKeyRangeGoneRetryPolicy(DiagnosticsClientContext diagnosticsClientContext,
@@ -53,9 +55,11 @@ public Mono<ShouldRetryResult> shouldRetry(Exception exception) {
         CosmosException clientException = Utils.as(exception, CosmosException.class);
         if (clientException != null &&
                 Exceptions.isStatusCode(clientException, HttpConstants.StatusCodes.GONE) &&
-                Exceptions.isSubStatusCode(clientException, HttpConstants.SubStatusCodes.PARTITION_KEY_RANGE_GONE)) {
+                (Exceptions.isSubStatusCode(clientException, HttpConstants.SubStatusCodes.PARTITION_KEY_RANGE_GONE)
+                    || Exceptions.isSubStatusCode(clientException, HttpConstants.SubStatusCodes.COMPLETING_SPLIT_OR_MERGE)
+                    || Exceptions.isSubStatusCode(clientException, HttpConstants.SubStatusCodes.COMPLETING_PARTITION_MIGRATION))) {
 
-            if (this.retried){
+            if (this.retryCount.getAndIncrement() >= MAX_RETRY_COUNT) {
                 return Mono.just(ShouldRetryResult.error(clientException));
             }
 
@@ -96,10 +100,8 @@ public Mono<ShouldRetryResult> shouldRetry(Exception exception) {
                 });
 
                 //  TODO: Check if this behavior can be replaced by doOnSubscribe
-                return refreshedRoutingMapObs.flatMap(rm -> {
-                    this.retried = true;
-                    return Mono.just(ShouldRetryResult.retryAfter(Duration.ZERO));
-                });
+                return refreshedRoutingMapObs.flatMap(rm ->
+                    Mono.just(ShouldRetryResult.retryAfter(Duration.ZERO)));
 
             });