We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5872a42 commit 1df4b29Copy full SHA for 1df4b29
proxy.go
@@ -232,7 +232,8 @@ func executeWithRetry(
232
if rw.StatusCode() == http.StatusBadGateway {
233
log.Debugf("the invalid host is: %s", s.host.addr)
234
s.host.penalize()
235
- s.host.dec()
+ // comment s.host.dec() line to avoid double increment; issue #322
236
+ // s.host.dec()
237
atomic.StoreUint32(&s.host.active, uint32(0))
238
newHost := s.host.replica.cluster.getHost()
239
// The query could be retried if it has no stickiness to a certain server
0 commit comments