diff options
author | Silvia Surroca <silvia.surroca@mongodb.com> | 2023-01-12 15:57:47 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2023-01-13 11:51:28 +0000 |
commit | 1b13e43a0c1262c6390f448d0ed692a9caa27166 (patch) | |
tree | 1c522f75b7334eea2301812c20f69b40bb0579b8 | |
parent | fd8260fc72cbe43f4addeab7bada2a87b05fb28c (diff) | |
download | mongo-1b13e43a0c1262c6390f448d0ed692a9caa27166.tar.gz |
SERVER-71924 Reduce verbosity of chunk merge change log event
(cherry picked from commit 04df1909dad97e26e26d45e6dfabf60ec67e20a9)
-rw-r--r-- | src/mongo/db/s/config/sharding_catalog_manager_chunk_operations.cpp | 24 |
1 files changed, 5 insertions, 19 deletions
diff --git a/src/mongo/db/s/config/sharding_catalog_manager_chunk_operations.cpp b/src/mongo/db/s/config/sharding_catalog_manager_chunk_operations.cpp index 2a4789e6b14..10683089620 100644 --- a/src/mongo/db/s/config/sharding_catalog_manager_chunk_operations.cpp +++ b/src/mongo/db/s/config/sharding_catalog_manager_chunk_operations.cpp @@ -940,25 +940,11 @@ StatusWith<BSONObj> ShardingCatalogManager::commitChunksMerge( // 5. log changes BSONObjBuilder logDetail; - { - initialVersion.appendLegacyWithField(&logDetail, "prevShardVersion"); - mergeVersion.appendLegacyWithField(&logDetail, "mergedVersion"); - logDetail.append("owningShard", shardId); - BSONArrayBuilder b(logDetail.subarrayStart("merged")); - - // Pad some slack to avoid exceeding max BSON size - const auto kBSONObjMaxLogDetailSize = BSONObjMaxUserSize - 3 * 1024; - for (const auto& chunkToMerge : *chunksToMerge) { - auto chunkBSON = chunkToMerge.toConfigBSON(); - - // Truncate the log if BSON log size exceeds BSONObjMaxUserSize - if (logDetail.len() + chunkBSON.objsize() >= kBSONObjMaxLogDetailSize) { - logDetail.append("mergedChunksArrayTruncatedToDontExceedMaxBSONSize", true); - break; - } - b.append(chunkBSON); - } - } + initialVersion.appendLegacyWithField(&logDetail, "prevShardVersion"); + mergeVersion.appendLegacyWithField(&logDetail, "mergedVersion"); + logDetail.append("owningShard", shardId); + chunkRange.append(&logDetail); + logDetail.append("numChunks", static_cast<int>(chunksToMerge->size())); ShardingLogging::get(opCtx)->logChange( opCtx, "merge", nss.ns(), logDetail.obj(), WriteConcernOptions()); |