mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2024-12-01 14:47:38 +00:00
vmagent: fix streamaggr config reload bug
https://github.com/VictoriaMetrics/VictoriaMetrics/issues/5170 Authored-by: luoshaojun01 <luoshaojun01@baidu.com>
This commit is contained in:
parent
26adfb3180
commit
4a8a4c67c1
1 changed files with 3 additions and 3 deletions
|
@ -743,12 +743,12 @@ func (rwctx *remoteWriteCtx) pushInternal(tss []prompbmarshal.TimeSeries) {
|
||||||
|
|
||||||
func (rwctx *remoteWriteCtx) reinitStreamAggr() {
|
func (rwctx *remoteWriteCtx) reinitStreamAggr() {
|
||||||
sas := rwctx.sas.Load()
|
sas := rwctx.sas.Load()
|
||||||
if sas == nil {
|
|
||||||
|
sasFile := streamAggrConfig.GetOptionalArg(rwctx.idx)
|
||||||
|
if sasFile == "" {
|
||||||
// There is no stream aggregation for rwctx
|
// There is no stream aggregation for rwctx
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
sasFile := streamAggrConfig.GetOptionalArg(rwctx.idx)
|
|
||||||
logger.Infof("reloading stream aggregation configs pointed by -remoteWrite.streamAggr.config=%q", sasFile)
|
logger.Infof("reloading stream aggregation configs pointed by -remoteWrite.streamAggr.config=%q", sasFile)
|
||||||
metrics.GetOrCreateCounter(fmt.Sprintf(`vmagent_streamaggr_config_reloads_total{path=%q}`, sasFile)).Inc()
|
metrics.GetOrCreateCounter(fmt.Sprintf(`vmagent_streamaggr_config_reloads_total{path=%q}`, sasFile)).Inc()
|
||||||
dedupInterval := streamAggrDedupInterval.GetOptionalArg(rwctx.idx)
|
dedupInterval := streamAggrDedupInterval.GetOptionalArg(rwctx.idx)
|
||||||
|
|
Loading…
Reference in a new issue