Log replication warnings when no error suppression is defined (#9320)
* Log replication warnings when no error suppression is defined * Add changelog file
This commit is contained in:
parent
6094b73d89
commit
2eac571276
|
@ -0,0 +1,3 @@
|
||||||
|
```release-note:bug
|
||||||
|
replication: Correctly log all replication warnings that should not be suppressed
|
||||||
|
```
|
|
@ -104,7 +104,7 @@ func (r *Replicator) Run(ctx context.Context) error {
|
||||||
// the next round of replication
|
// the next round of replication
|
||||||
atomic.StoreUint64(&r.lastRemoteIndex, 0)
|
atomic.StoreUint64(&r.lastRemoteIndex, 0)
|
||||||
|
|
||||||
if r.suppressErrorLog != nil && !r.suppressErrorLog(err) {
|
if r.suppressErrorLog == nil || !r.suppressErrorLog(err) {
|
||||||
r.logger.Warn("replication error (will retry if still leader)", "error", err)
|
r.logger.Warn("replication error (will retry if still leader)", "error", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue