Fix bugs

elastic · Mar 19, 2024 · 1515711 · 1515711
1 parent 9c87e7e
commit 1515711
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/x-pack/filebeat/input/salesforce/input.go b/x-pack/filebeat/input/salesforce/input.go
@@ -190,7 +190,7 @@ func (s *salesforceInput) SetupSFClientConnection() (*soql.Resource, error) {
 		return nil, err
 	}
 
-	// set clientSession for re-use (EventLogFile)
+	// Set clientSession for re-use.
 	s.clientSession = session
 
 	// Create a new SOQL resource using the session.
@@ -494,6 +494,10 @@ func newClient(cfg config, log *logp.Logger) (*http.Client, error) {
 			Backoff:      retryablehttp.DefaultBackoff,
 			ErrorHandler: retryErrorHandler(maxAttempts, log),
 		}).StandardClient()
+
+		// BUG: retryablehttp ignores the timeout previously set. So, setting it
+		// again.
+		c.Timeout = cfg.Resource.Transport.Timeout
 	}
 
 	return c, nil