refactor

2022-05-11 17:42:16 +08:00 · 2022-05-11 17:42:16 +08:00 · 84c21b4801
parent 7978cc6b80
commit 84c21b4801
1 changed files with 5 additions and 0 deletions
--- a/agent/reader.go
+++ b/agent/reader.go
@ -113,6 +113,11 @@ func (r *Reader) read() {
 				// queue closed
 				return
 			}
+
+			if item == nil {
+				continue
+			}
+
 			series = append(series, convert(item))
 			count++
 			if count >= batch {