Skip to content

Nregion synchronous commit feature#47757

Merged
mbhaskar merged 17 commits into
Azure:mainfrom
mbhaskar:nregioncommit
Feb 12, 2026
Merged

Nregion synchronous commit feature#47757
mbhaskar merged 17 commits into
Azure:mainfrom
mbhaskar:nregioncommit

Fixing swith statement

137e989
Select commit
Loading
Failed to load commit list.
Azure Pipelines / java - cosmos - ci succeeded Feb 11, 2026 in 1h 16m 43s

Build #20260210.12 had test failures

0 errors / 7,694 warnings

Details

Tests

  • Failed: 3 (0.01%)
  • Passed: 56,924 (98.67%)
  • Other: 767 (1.33%)
  • Total: 57,694
Code coverage

  • 2403 of 81471 lines covered (2.95%)

Annotations

Check failure on line 1 in c.a.c.s.PointWriterITest.Point Writer can create item with duplicates

See this annotation in the file changed.

@azure-pipelines azure-pipelines / java - cosmos - ci

c.a.c.s.PointWriterITest.Point Writer can create item with duplicates 

{"innerErrorMessage":"{\"innerErrorMessage\":\"ChannelHandlerContext(RntbdRequestManager#0, [id: 0x66715a8d, L:/127.0.0.1:63920 - R:/127.0.0.1:10253]) closed exceptionally with 1 pending requests\"}","cosmosDiagnostics":{"userAgent":"azsdk-java-cosmos/4.78.0-snapshot.1 WindowsServer2022/10.0 JRE/17.0.17","activityId":"d18d0f96-3596-402a-a41b-567228b80d12","requestLatencyInMs":1572,"requestStartTimeUTC":"2026-02-10T19:58:09.602664700Z","requestEndTimeUTC":"2026-02-10T19:58:11.174927700Z","responseStatisticsList":[{"storeResult":{"storePhysicalAddress":"rntbd://127.0.0.1:10253/apps/DocDbApp/services/DocDbServer37/partitions/a4cb4971-38c8-11e6-8106-8cdcd42c33be/replicas/1p/","lsn":0,"quorumAckedLSN":-1,"currentReplicaSetSize":-1,"globalCommittedLsn":-1,"globalNRegionCommittedGlsn":-1,"partitionKeyRangeId":null,"isValid":true,"statusCode":410,"subStatusCode":0,"isGone":true,"isNotFound":false,"isInvalidPartition":false,"isThroughputControlRequestRateTooLarge":false,"requestCharge":0.0,"itemLSN":-1,"sessionToken":null,"backendLatencyInMs":null,"retryAfterInMs":null,"exceptionMessage":"ChannelHandlerContext(RntbdRequestManager#0, [id: 0x66715a8d, L:/127.0.0.1:63920 - R:/127.0.0.1:10253]) closed exceptionally with 1 pending requests","exceptionResponseHeaders":"{x-ms-substatus=0}","replicaStatusList":{"Ignoring":["10253:S:Connected"],"Attempting":["10253:P:Connected"]},"transportRequestTimeline":[{"eventName":"created","startTimeUTC":"2026-02-10T19:58:09.602664700Z","durationInMilliSecs":0.0},{"eventName":"queued","startTimeUTC":"2026-02-10T19:58:09.602664700Z","durationInMilliSecs":0.0},{"eventName":"channelAcquisitionStarted","startTimeUTC":"2026-02-10T19:58:09.602664700Z","durationInMilliSecs":31.0088},{"eventName":"pipelined","startTimeUTC":"2026-02-10T19:58:09.633673500Z","durationInMilliSecs":7.9967},{"eventName":"transitTime","startTimeUTC":"2026-02-10T19:58:09.641670200Z","durationInMilliSecs":1.0017},{"eventName":"decodeTime","startTimeUTC":null,"durationInMilliSecs":0.0},{"eventName":"received","startTimeUTC":null,"durationInMilliSecs":0.0},{"eventName":"completed","startTimeUTC":"2026-02-10T19:58:09.642671900Z","durationInMilliSecs":0.0}],"rntbdRequestLengthInBytes":511,"rntbdResponseLengthInBytes":-1,"requestPayloadLengthInBytes":103,"responsePayloadLengthInBytes":-1,"channelStatistics":{"channelId":"66715a8d","channelTaskQueueSize":1,"pendingRequestsCount":0,"lastReadTime":"2026-02-10T19:58:09.632677100Z","waitForConnectionInit":false},"serviceEndpointStatistics":{"availableChannels":29,"acquiredChannels":1,"executorTaskQueueSize":31,"inflightRequests":32,"lastSuccessfulRequestTime":"2026-02-10T19:58:09.601Z","lastRequestTime":"2026-02-10T19:58:09.602Z","createdTime":"2026-02-10T19:57:43.232240500Z","isClosed":false,"cerMetrics":{}}},"requestResponseTimeUTC":"2026-02-10T19:58:09.648674Z","requestStartTimeUTC":"2026-02-10T19:58:09.602664700Z","requestResourceType":"Document","requestOperationType":"Create","requestSessionToken":null,"e2ePolicyCfg":null,"excludedRegions":null,"sessionTokenEvaluationResults":[],"perPartitionCircuitBreakerInfoHolder":null,"perPartitionAutomaticFailoverInfoHolder":null,"isHubRegionProcessingOnly":"false","perPartitionFailoverInfoHolder":null}],"supplementalResponseStatisticsList":[],"addressResolutionStatistics":{"d499e2c0-d521-4242-aa0c-326a5ca90e2e":{"startTimeUTC":"2026-02-10T19:58:11.175921200Z","endTimeUTC":null,"targetEndpoint":"https://127.0.0.1:8081/addresses/?$resolveFor=dbs%2FOi5UAA%3D%3D%2Fcolls%2FOi5UALlj0Es%3D%2Fdocs&$filter=protocol%20eq%20rntbd&$partitionKeyRangeIds=1","exceptionMessage":null,"forceRefresh":true,"forceCollectionRoutingMapRefresh":false,"inflightRequest":true},"91aaa31f-e361-4cf2-85ba-6e83feaa21ea":{"startTimeUTC":"2026-02-10T19:58:10.666925400Z","endTimeUTC":"2026-02-10T19:58:11.174927700Z","targetEndpoint":"https://127.0.0.1:8081/addresses/?$resolveFor=dbs%2FOi5UAA%3D%3D%2Fcolls%2FOi5UALlj0Es%3D%2Fdocs&$filter=protocol%20eq%20rntbd&$partitionKeyRangeIds=1","ex
Raw output 
      {"ClassName":"CosmosException","userAgent":"azsdk-java-cosmos/4.78.0-snapshot.1 WindowsServer2022/10.0 JRE/17.0.17","statusCode":408,"resourceAddress":null,"innerErrorMessage":"{\"innerErrorMessage\":\"ChannelHandlerContext(RntbdRequestManager#0, [id: 0x66715a8d, L:/127.0.0.1:63920 - R:/127.0.0.1:10253]) closed exceptionally with 1 pending requests\"}","causeInfo":"[class: class com.azure.cosmos.implementation.GoneException, message: {\"innerErrorMessage\":\"ChannelHandlerContext(RntbdRequestManager#0, [id: 0x66715a8d, L:/127.0.0.1:63920 - R:/127.0.0.1:10253]) closed exceptionally with 1 pending requests\"}]","responseHeaders":"{x-ms-substatus=0}","cosmosDiagnostics":{"userAgent":"azsdk-java-cosmos/4.78.0-snapshot.1 WindowsServer2022/10.0 JRE/17.0.17","activityId":"d18d0f96-3596-402a-a41b-567228b80d12","requestLatencyInMs":1682,"requestStartTimeUTC":"2026-02-10T19:58:09.602664700Z","requestEndTimeUTC":"2026-02-10T19:58:11.284921600Z","responseStatisticsList":[{"storeResult":{"storePhysicalAddress":"rntbd://127.0.0.1:10253/apps/DocDbApp/services/DocDbServer37/partitions/a4cb4971-38c8-11e6-8106-8cdcd42c33be/replicas/1p/","lsn":0,"quorumAckedLSN":-1,"currentReplicaSetSize":-1,"globalCommittedLsn":-1,"globalNRegionCommittedGlsn":-1,"partitionKeyRangeId":null,"isValid":true,"statusCode":410,"subStatusCode":0,"isGone":true,"isNotFound":false,"isInvalidPartition":false,"isThroughputControlRequestRateTooLarge":false,"requestCharge":0.0,"itemLSN":-1,"sessionToken":null,"backendLatencyInMs":null,"retryAfterInMs":null,"exceptionMessage":"ChannelHandlerContext(RntbdRequestManager#0, [id: 0x66715a8d, L:/127.0.0.1:63920 - R:/127.0.0.1:10253]) closed exceptionally with 1 pending requests","exceptionResponseHeaders":"{x-ms-substatus=0}","replicaStatusList":{"Ignoring":["10253:S:Connected"],"Attempting":["10253:P:Connected"]},"transportRequestTimeline":[{"eventName":"created","startTimeUTC":"2026-02-10T19:58:09.602664700Z","durationInMilliSecs":0.0},{"eventName":"queued","startTimeUTC":"2026-02-10T19:58:09.602664700Z","durationInMilliSecs":0.0},{"eventName":"channelAcquisitionStarted","startTimeUTC":"2026-02-10T19:58:09.602664700Z","durationInMilliSecs":31.0088},{"eventName":"pipelined","startTimeUTC":"2026-02-10T19:58:09.633673500Z","durationInMilliSecs":7.9967},{"eventName":"transitTime","startTimeUTC":"2026-02-10T19:58:09.641670200Z","durationInMilliSecs":1.0017},{"eventName":"decodeTime","startTimeUTC":null,"durationInMilliSecs":0.0},{"eventName":"received","startTimeUTC":null,"durationInMilliSecs":0.0},{"eventName":"completed","startTimeUTC":"2026-02-10T19:58:09.642671900Z","durationInMilliSecs":0.0}],"rntbdRequestLengthInBytes":511,"rntbdResponseLengthInBytes":-1,"requestPayloadLengthInBytes":103,"responsePayloadLengthInBytes":-1,"channelStatistics":{"channelId":"66715a8d","channelTaskQueueSize":1,"pendingRequestsCount":0,"lastReadTime":"2026-02-10T19:58:09.632677100Z","waitForConnectionInit":false},"serviceEndpointStatistics":{"availableChannels":29,"acquiredChannels":1,"executorTaskQueueSize":31,"inflightRequests":32,"lastSuccessfulRequestTime":"2026-02-10T19:58:09.601Z","lastRequestTime":"2026-02-10T19:58:09.602Z","createdTime":"2026-02-10T19:57:43.232240500Z","isClosed":false,"cerMetrics":{}}},"requestResponseTimeUTC":"2026-02-10T19:58:09.648674Z","requestStartTimeUTC":"2026-02-10T19:58:09.602664700Z","requestResourceType":"Document","requestOperationType":"Create","requestSessionToken":null,"e2ePolicyCfg":null,"excludedRegions":null,"sessionTokenEvaluationResults":[],"perPartitionCircuitBreakerInfoHolder":null,"perPartitionAutomaticFailoverInfoHolder":null,"isHubRegionProcessingOnly":"false","perPartitionFailoverInfoHolder":null}],"supplementalResponseStatisticsList":[],"addressResolutionStatistics":{"d499e2c0-d521-4242-aa0c-326a5ca90e2e":{"startTimeUTC":"2026-02-10T19:58:11.175921200Z","endTimeUTC":"2026-02-10T19:58:11.284921600Z","targetEndpoint":"https://127.0.0.1:8081/addresses/?$resolveFor=dbs%2FOi5UAA%3D%3D%2Fcolls%2FOi

Check failure on line 1 in c.a.c.r.ContainerCreateDeleteWithSameNameTest.ContainerCreateDeleteWithSameNameTest::bulk[Gateway with Session consistency][10100, /mypk, com.azure.cosmos.rx.ContainerCreateDeleteWithSameNameTest$2@947054a, 400, /id, com.azure.cosmos.rx.ContainerCreateDeleteWithSameNameTest$1@4061e3dd](4)

See this annotation in the file changed.

@azure-pipelines azure-pipelines / java - cosmos - ci

c.a.c.r.ContainerCreateDeleteWithSameNameTest.ContainerCreateDeleteWithSameNameTest::bulk[Gateway with Session consistency][10100, /mypk, com.azure.cosmos.rx.ContainerCreateDeleteWithSameNameTest$2@947054a, 400, /id, com.azure.cosmos.rx.ContainerCreateDeleteWithSameNameTest$1@4061e3dd](4) 

[total number of results] 
expected: 10
 but was: 8
Raw output 
java.lang.AssertionError: 
[total number of results] 
expected: 10
 but was: 8
	at com.azure.cosmos.implementation.FeedResponseListValidator$Builder$2.validate(FeedResponseListValidator.java:56)
	at com.azure.cosmos.implementation.FeedResponseListValidator$Builder$1.validate(FeedResponseListValidator.java:44)
	at reactor.test.DefaultStepVerifierBuilder.lambda$consumeNextWith$1(DefaultStepVerifierBuilder.java:279)
	at reactor.test.DefaultStepVerifierBuilder$SignalEvent.test(DefaultStepVerifierBuilder.java:2289)
	at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onSignal(DefaultStepVerifierBuilder.java:1529)
	at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onExpectation(DefaultStepVerifierBuilder.java:1477)
	at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onNext(DefaultStepVerifierBuilder.java:1146)
	at reactor.core.publisher.Operators$BaseFluxToMonoOperator.completePossiblyEmpty(Operators.java:2096)
	at reactor.core.publisher.MonoCollectList$MonoCollectListSubscriber.onComplete(MonoCollectList.java:118)
	at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277)
	at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126)
	at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940)
	at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940)
	at reactor.core.publisher.FluxDoOnEach$DoOnEachSubscriber.onComplete(FluxDoOnEach.java:223)
	at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:850)
	at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612)
	at reactor.core.publisher.FluxFlatMap$FlatMapMain.innerComplete(FluxFlatMap.java:898)
	at reactor.core.publisher.FluxFlatMap$FlatMapInner.onComplete(FluxFlatMap.java:1001)
	at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144)
	at reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:260)
	at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2230)
	at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:850)
	at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612)
	at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:592)
	at reactor.core.publisher.FluxFlatMap$FlatMapMain.onComplete(FluxFlatMap.java:469)
	at reactor.core.publisher.SerializedSubscriber.onComplete(SerializedSubscriber.java:146)
	at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onComplete(FluxRetryWhen.java:204)
	at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:850)
	at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612)
	at reactor.core.publisher.FluxFlatMap$FlatMapMain.innerComplete(FluxFlatMap.java:898)
	at reactor.core.publisher.FluxFlatMap$FlatMapInner.onComplete(FluxFlatMap.java:1001)
	at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144)
	at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:85)
	at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144)
	at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144)
	at reactor.core.publisher.FluxSkip$SkipSubscriber.onComplete(FluxSkip.java:102)
	at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144)
	at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:209)
	at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144)
	at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:166)
	at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.drain(FluxMergeSequential.java:374)
	at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.

Check failure on line 1 in c.a.c.r.ContainerCreateDeleteWithSameNameTest.bulk

See this annotation in the file changed.

@azure-pipelines azure-pipelines / java - cosmos - ci

c.a.c.r.ContainerCreateDeleteWithSameNameTest.bulk 

[total number of results]  expected: 10  but was: 8
Raw output 
java.lang.AssertionError: [total number of results] 
expected: 10
 but was: 8
at com.azure.cosmos.implementation.FeedResponseListValidator$Builder$2.validate(FeedResponseListValidator.java:56)
at com.azure.cosmos.implementation.FeedResponseListValidator$Builder$1.validate(FeedResponseListValidator.java:44)
at reactor.test.DefaultStepVerifierBuilder.lambda$consumeNextWith$1(DefaultStepVerifierBuilder.java:279)
at reactor.test.DefaultStepVerifierBuilder$SignalEvent.test(DefaultStepVerifierBuilder.java:2289)
at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onSignal(DefaultStepVerifierBuilder.java:1529)
at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onExpectation(DefaultStepVerifierBuilder.java:1477)
at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onNext(DefaultStepVerifierBuilder.java:1146)
at reactor.core.publisher.Operators$BaseFluxToMonoOperator.completePossiblyEmpty(Operators.java:2096)
at reactor.core.publisher.MonoCollectList$MonoCollectListSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277)
at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126)
at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940)
at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940)
at reactor.core.publisher.FluxDoOnEach$DoOnEachSubscriber.onComplete(FluxDoOnEach.java:223)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:850)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.innerComplete(FluxFlatMap.java:898)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.onComplete(FluxFlatMap.java:1001)
at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144)
at reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:260)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2230)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:850)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:592)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onComplete(FluxFlatMap.java:469)
at reactor.core.publisher.SerializedSubscriber.onComplete(SerializedSubscriber.java:146)
at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onComplete(FluxRetryWhen.java:204)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:850)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.innerComplete(FluxFlatMap.java:898)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.onComplete(FluxFlatMap.java:1001)
at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144)
at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:85)
at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144)
at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144)
at reactor.core.publisher.FluxSkip$SkipSubscriber.onComplete(FluxSkip.java:102)
at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144)
at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:209)
at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144)
at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:166)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.drain(FluxMergeSequential.java:374)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.innerComplete(FluxMergeSequential.java:335)
View more details on Azure Pipelines