x-pack/filebeat/input/{azureblobstorage,gcs,httpjson}: fix error logg…

…ing verbs (#41042)

x-pack/filebeat/input/azureblobstorage/job.go

@@ -28,7 +28,7 @@ import (
  "github.com/elastic/elastic-agent-libs/mapstr"
 )
 
-const jobErrString = "job with jobId %s encountered an error: %w"
+const jobErrString = "job with jobId %s encountered an error: %v"
 
 type job struct {
  // client is an azure blob handle

x-pack/filebeat/input/gcs/scheduler.go

@@ -232,7 +232,7 @@ func (s *scheduler) addFailedJobs(ctx context.Context, jobs []*job) []*job {
  if !jobMap[name] {
  obj, err := s.bucket.Object(name).Attrs(ctx)
  if err != nil {
- s.log.Errorf("adding failed job %s to job list caused an error: %w", err)
+ s.log.Errorf("adding failed job %s to job list caused an error: %v", name, err)
  continue
  }
 

x-pack/filebeat/input/httpjson/request.go

@@ -576,7 +576,7 @@ func (p *chainProcessor) handleEvent(ctx context.Context, msg mapstr.M) {
  // we construct a new response here from each of the pagination events
  err := json.NewEncoder(body).Encode(msg)
  if err != nil {
- p.req.log.Errorf("error processing chain event: %w", err)
+ p.req.log.Errorf("error processing chain event: %v", err)
  return
  }
  response.Body = io.NopCloser(body)
@@ -589,17 +589,17 @@ func (p *chainProcessor) handleEvent(ctx context.Context, msg mapstr.M) {
  n, err := p.req.processChainPaginationEvents(ctx, p.trCtx, p.pub, &response, p.idx, p.req.log)
  if err != nil {
  if errors.Is(err, notLogged{}) {
- p.req.log.Debugf("ignored error processing chain event: %w", err)
+ p.req.log.Debugf("ignored error processing chain event: %v", err)
  return
  }
- p.req.log.Errorf("error processing chain event: %w", err)
+ p.req.log.Errorf("error processing chain event: %v", err)
  return
  }
  p.n += n
 
  err = response.Body.Close()
  if err != nil {
- p.req.log.Errorf("error closing http response body: %w", err)
+ p.req.log.Errorf("error closing http response body: %v", err)
  }
 }