[BUG] Error while creating Azure cosmos documents in batches through Java SDK version 4.28.0

[prabhuperumalofficial]

Describe the bug
We have integrated azure-cosmos SDK version 4.28.0 in our Spring Boot app version 2.7.2 which running on Java 11. This program creates Cosmos documents in batches and it was working great from day 1 of integration back in Dec 2022. All of a sudden from the last 3 days, it started creating a partial set of documents in the batches (Eg. Only 558 documents created in a 1000 documents batch) we havent seen this error before in the last 3+ years

ERROR log: pki 0 failed to import mini-batch. Exception was Missing partition key header for point operation ActivityId: 2c4e15ec-4531-4d04-9fbf-58722c93ee5d, Windows/10.0.20348 cosmos-netstandard-sdk/3.18.0, StatusCode: BadRequest. Status code was 400

Exception or Stack Trace
pki 0 failed to import mini-batch. Exception was Missing partition key header for point operation ActivityId: 2c4e15ec-4531-4d04-9fbf-58722c93ee5d, Windows/10.0.20348 cosmos-netstandard-sdk/3.18.0, StatusCode: BadRequest. Status code was 400

Sample Code:
Spring boot version - 2.7.2
Azure Cosmos SDK - 4.28.0
Java 11

DocumentBulkExecutor.Builder bulkExecutorBuilder = DocumentBulkExecutor.builder().from(
        cosmosDBClient,
        DATABASE_ID,
        SCH_SLOTS_COLLECTION_ID,
        getDocumentCollection().getPartitionKey(),
        createThroughput);

DocumentBulkExecutor bulkExecutor = bulkExecutorBuilder.build();
BulkImportResponse bulkImportResponse = bulkExecutor.importAll(documents, false,
        true, null);

[github-actions]

Thanks for the feedback! We are routing this to the appropriate team for follow-up. cc @kushagraThapar @pjohari-ms @TheovanKraay.

[prabhuperumalofficial]

And this issue is not happening always, and it is failing randomly like a 1 in 20 ratio

[prabhuperumalofficial]

Stacktrace:
com.microsoft.azure.documentdb.DocumentClientException: Missing partition key header for point operation
ActivityId: 5da781bf-fb0e-40be-823b-382627013333, Windows/10.0.20348 cosmos-netstandard-sdk/3.18.0, StatusCode: BadRequest
at com.microsoft.azure.documentdb.internal.ErrorUtils.maybeThrowException(ErrorUtils.java:74)
at com.microsoft.azure.documentdb.internal.GatewayProxy.performPostRequest(GatewayProxy.java:284)
at com.microsoft.azure.documentdb.internal.GatewayProxy.doExecute(GatewayProxy.java:108)
at com.microsoft.azure.documentdb.internal.GatewayProxy.processMessage(GatewayProxy.java:360)
at com.microsoft.azure.documentdb.DocumentClient$5.apply(DocumentClient.java:3037)
at com.microsoft.azure.documentdb.internal.RetryUtility.executeDocumentClientRequest(RetryUtility.java:73)
at com.microsoft.azure.documentdb.DocumentClient.doCreate(DocumentClient.java:3042)
at com.microsoft.azure.documentdb.DocumentClient.executeStoredProcedure(DocumentClient.java:1571)
at com.microsoft.azure.documentdb.bulkexecutor.internal.BatchInserter$1.call(BatchInserter.java:188)
at com.microsoft.azure.documentdb.bulkexecutor.internal.BatchInserter$1.call(BatchInserter.java:159)
at com.microsoft.azure.documentdb.repackaged.com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:125)
at com.microsoft.azure.documentdb.repackaged.com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:57)
at com.microsoft.azure.documentdb.repackaged.com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:78)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)