From 2e28e78a7e18afca60225837fb21a027e5538035 Mon Sep 17 00:00:00 2001
From: kongfei <kongfei605@gmail.com>
Date: Mon, 11 Nov 2024 10:03:39 +0800
Subject: [PATCH] fix: (logs-agent) retry to get pod list when connection
 broken

---
 logs/input/kubernetes/scanner.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/logs/input/kubernetes/scanner.go b/logs/input/kubernetes/scanner.go
index db2f3369..71caa955 100644
--- a/logs/input/kubernetes/scanner.go
+++ b/logs/input/kubernetes/scanner.go
@@ -53,7 +53,7 @@ func (s *Scanner) Scan() {
 			pods, err := s.kubelet.GetLocalPodList(ctx)
 			if err != nil {
 				log.Printf("get local pod list error %s", err)
-				return
+				continue
 			}
 			fetched := make(map[string]checksum.Checksum)
 			for _, pod := range pods {