diff options
author | Pierlauro Sciarelli <pierlauro.sciarelli@mongodb.com> | 2022-12-05 11:33:13 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-12-21 14:06:28 +0000 |
commit | 9ba29038b9316acb6f0a5a414285ca39fddb3fa5 (patch) | |
tree | e8780aa23ef944ddd27d0937a6ff827559a5a17d | |
parent | f5588ecf825dcb0b05cea9c744a374b129e4b452 (diff) | |
download | mongo-9ba29038b9316acb6f0a5a414285ca39fddb3fa5.tar.gz |
SERVER-71787 Balancer needs to attach forceJumbo to `moveRange` command
-rw-r--r-- | src/mongo/db/s/balancer/balancer.cpp | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/src/mongo/db/s/balancer/balancer.cpp b/src/mongo/db/s/balancer/balancer.cpp index f4752f3d12d..a9b4aa0cb6f 100644 --- a/src/mongo/db/s/balancer/balancer.cpp +++ b/src/mongo/db/s/balancer/balancer.cpp @@ -1054,6 +1054,16 @@ int Balancer::_moveChunks(OperationContext* opCtx, shardSvrRequest.setMaxChunkSizeBytes(maxChunkSizeBytes); shardSvrRequest.setFromShard(migrateInfo.from); shardSvrRequest.setEpoch(migrateInfo.version.epoch()); + const auto forceJumbo = [&]() { + if (migrateInfo.forceJumbo == MoveChunkRequest::ForceJumbo::kForceManual) { + return ForceJumbo::kForceManual; + } + if (migrateInfo.forceJumbo == MoveChunkRequest::ForceJumbo::kForceBalancer) { + return ForceJumbo::kForceBalancer; + } + return ForceJumbo::kDoNotForce; + }(); + shardSvrRequest.setForceJumbo(forceJumbo); const auto [secondaryThrottle, wc] = getSecondaryThrottleAndWriteConcern(balancerConfig->getSecondaryThrottle()); shardSvrRequest.setSecondaryThrottle(secondaryThrottle); |