Filebeat gcs input addFiledJobs panic protection (#38407)

* Filebeat gcs input addFiledJobs panic protection In case `obj, err := s.bucket.Object(name).Attrs(ctx)` return an error, obj will be probably `nil` in consequence the code below will panic `objectURI := "gs://" + s.src.BucketName + "/" + obj.Name` * Update CHANGELOG-developer.next.asciidoc
elastic · Mar 20, 2024 · c6fd99c · c6fd99c
1 parent 10ff992
commit c6fd99c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/CHANGELOG-developer.next.asciidoc b/CHANGELOG-developer.next.asciidoc
@@ -92,6 +92,7 @@ The list below covers the major changes between 7.0.0-rc2 and main only.
 - Make winlogbeat/sys/wineventlog follow the unsafe.Pointer rules. {pull}36650[36650]
 - Cleaned up documentation errors & fixed a minor bug in Filebeat Azure blob storage input. {pull}36714[36714]
 - Fix copy arguments for strict aligned architectures. {pull}36976[36976]
+- Fix filebit gcs input panic {pull}38407[38407]
 
 ==== Added
 

diff --git a/x-pack/filebeat/input/gcs/scheduler.go b/x-pack/filebeat/input/gcs/scheduler.go
@@ -233,6 +233,7 @@ func (s *scheduler) addFailedJobs(ctx context.Context, jobs []*job) []*job {
 			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)
+				continue
 			}
 
 			objectURI := "gs://" + s.src.BucketName + "/" + obj.Name