CosmosDB Java V4 SDK批量操作出现FAIL_TERMINATED日志该如何处理？

我在使用CosmosDB容器执行简单文档更新时，调用container.executeBulkOperations(bulkOperations)，发现底层输出了以下INFO级别的日志：

...lementation.batch.BulkExecutor:862 - Closing all sinks, Context: BulkExecutor-1[n/a]
...lementation.batch.BulkExecutor:862 - Closing all sinks, Context: BulkExecutor-1[n/a]
...lementation.batch.BulkExecutor:869 - Main sink completion failed. EmitResult: FAIL_TERMINATED, Context: BulkExecutor-1[n/a]
...lementation.batch.BulkExecutor:862 - Closing all sinks, Context: BulkExecutor-1[n/a]
...lementation.batch.BulkExecutor:869 - Main sink completion failed. EmitResult: FAIL_TERMINATED, Context: BulkExecutor-1[n/a]

我需要显式终止批量操作吗？我的操作有没有问题？这些INFO日志可以忽略吗？

示例代码：

public static final String PARTITION_ID = "BULK_DATA_PARTITION";
@Inject
@CosmosBalConfiguration.BalBalancesContainer
CosmosAsyncContainer container;

record IdAndPartition(String id, String partitionId){};

void simpleDummyBulkUpdate() {
    Flux<CosmosItemOperation> bulkOperations = Flux.range(0, 10).map(i -> CosmosBulkOperations.getUpsertItemOperation(new IdAndPartition(i.toString(), PARTITION_ID), new PartitionKey(PARTITION_ID)));
    container.executeBulkOperations(bulkOperations)
            .blockLast();
}

回答 #

• 无需显式终止批量操作：SDK内部会自动管理批量操作的生命周期，包括资源清理和终止流程。你的代码中用blockLast()已经等待了批量操作全部完成，不需要额外调用终止方法。
• 日志属于正常流程记录：这些INFO级别日志是SDK内部批量执行器的状态输出——Closing all sinks表示批量操作结束后正在清理内部数据流接收器；Main sink completion failed. EmitResult: FAIL_TERMINATED并非错误，而是操作完成后接收器被正常终止的状态反馈，属于SDK内部的常规流程日志。
• 你的操作没有问题：从示例代码看，批量操作的构建和执行逻辑是正确的：用Flux生成操作列表，调用executeBulkOperations后用blockLast()等待执行完成。只要数据能正常完成upsert，这些日志完全可以忽略。

内容的提问来源于stack exchange，提问作者Jan Peremský