influxdb timeout fix

This commit is contained in:
Anton Evangelatov 2019-03-20 14:31:31 +01:00
parent ecaaa1231a
commit 097651c2c7
2 changed files with 1 additions and 1 deletions

View file

@ -91,6 +91,7 @@ func (r *reporter) makeClient() (err error) {
URL: r.url, URL: r.url,
Username: r.username, Username: r.username,
Password: r.password, Password: r.password,
Timeout: 10 * time.Second,
}) })
return return

View file

@ -536,7 +536,6 @@ func (r *LazyChunkReader) join(ctx context.Context, b []byte, off int64, eoff in
chunkData, err := r.getter.Get(ctx, Reference(childAddress)) chunkData, err := r.getter.Get(ctx, Reference(childAddress))
if err != nil { if err != nil {
metrics.GetOrRegisterResettingTimer("lcr.getter.get.err", nil).UpdateSince(startTime) metrics.GetOrRegisterResettingTimer("lcr.getter.get.err", nil).UpdateSince(startTime)
log.Debug("lazychunkreader.join", "key", fmt.Sprintf("%x", childAddress), "err", err)
select { select {
case errC <- fmt.Errorf("chunk %v-%v not found; key: %s", off, off+treeSize, fmt.Sprintf("%x", childAddress)): case errC <- fmt.Errorf("chunk %v-%v not found; key: %s", off, off+treeSize, fmt.Sprintf("%x", childAddress)):
case <-quitC: case <-quitC: