Skip to content

Commit d5677ea

Browse files
committed
Fix merger
1 parent a54897f commit d5677ea

File tree

2 files changed

+1
-3
lines changed

2 files changed

+1
-3
lines changed

ydb/core/blobstorage/vdisk/balance/balancing_actor.cpp

+1-2
Original file line numberDiff line numberDiff line change
@@ -145,6 +145,7 @@ namespace NBalancing {
145145
continue;
146146
}
147147

148+
merger.Clear();
148149
It.PutToMerger(&merger);
149150

150151
auto [moveMask, delMask] = merger.Ingress.HandoffParts(&top, Ctx->VCtx->ShortSelfVDisk, key);
@@ -183,8 +184,6 @@ namespace NBalancing {
183184
}
184185
}
185186

186-
merger.Clear();
187-
188187
if (SendOnMainParts.Size() >= Ctx->Cfg.MaxToSendPerEpoch && TryDeleteParts.Size() >= Ctx->Cfg.MaxToDeletePerEpoch) {
189188
// reached the limit of parts to send and delete
190189
break;

ydb/core/blobstorage/vdisk/balance/utils.cpp

-1
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,6 @@ namespace NBalancing {
7878
void TPartsCollectorMerger::Clear() {
7979
Ingress = TIngress();
8080
Parts.clear();
81-
Parts.resize(GType.TotalPartCount());
8281
}
8382

8483
} // NBalancing

0 commit comments

Comments
 (0)