Kiu/VictoriaMetrics
Kiu/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2025-01-05 22:32:20 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

app/vminsert/netstorage: emit warnings instead of errors when re-routing data to healthy storage nodes

Browse Source
This commit is contained in:
Aliaksandr Valialkin 2020-05-27 16:31:41 +03:00
parent 75f2f3b09d
commit b4e3bffe4b
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/vminsert/netstorage/netstorage.go
View File

@ -116,7 +116,7 @@ func (sn *storageNode) run(stopCh <-chan struct{}) {
if len(br.buf) == 0 { if len(br.buf) == 0 {
continue continue
} }
logger.Errorf("re-routing %d bytes with %d rows to other storage nodes because cannot dial storageNode %q: %s", logger.Warnf("re-routing %d bytes with %d rows to other storage nodes because cannot dial storageNode %q: %s",
len(br.buf), br.rows, sn.dialer.Addr(), err) len(br.buf), br.rows, sn.dialer.Addr(), err)
if addToReroutedBufNonblock(br.buf, br.rows) { if addToReroutedBufNonblock(br.buf, br.rows) {
sn.rowsReroutedFromHere.Add(br.rows) sn.rowsReroutedFromHere.Add(br.rows)
@ -135,7 +135,7 @@ func (sn *storageNode) run(stopCh <-chan struct{}) {
// Couldn't flush buf to sn. Mark sn as broken // Couldn't flush buf to sn. Mark sn as broken
// and try re-routing buf to healthy vmstorage nodes. // and try re-routing buf to healthy vmstorage nodes.
if err = bc.Close(); err != nil { if err = bc.Close(); err != nil {
logger.Errorf("cannot close connection to storageNode %q: %s", sn.dialer.Addr(), err) logger.Warnf("cannot close connection to storageNode %q: %s", sn.dialer.Addr(), err)
// continue executing the code below. // continue executing the code below.
} }
bc = nil bc = nil