rms/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2026-05-17 00:26:36 +03:00
Code Issues Packages Projects Releases Wiki Activity

address review comment

Browse Source
This commit is contained in:
Max Kotliar
2026-05-13 16:15:35 +03:00
parent e55cb121e0
commit 051a059d30
1 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
app/vmagent/remotewrite/remotewrite.go
View File

@@ -507,12 +507,9 @@ func tryPush(at *auth.Token, wr *prompb.WriteRequest, forceDropSamplesOnFailure
//
// calculateHealthyRwctxIdx will rely on the order of rwctx to be in ascending order.
func getEligibleRemoteWriteCtxs(tss []prompb.TimeSeries, forceDropSamplesOnFailure bool) ([]*remoteWriteCtx, bool) {
// Always use all configured remote writes in order to preserve stable metrics distribution across shards.
// When -remoteWrite.shardByURL=true always use all configured remote writes to preserve stable metrics distribution across shards.
// See https://github.com/VictoriaMetrics/VictoriaMetrics/issues/10507
if *shardByURL {
return rwctxsGlobal, true
}
if !disableOnDiskQueueAny {
if !disableOnDiskQueueAny || *shardByURL {
return rwctxsGlobal, true
}