Fix netflow panic (#457)

Co-authored-by: anjmao <[email protected]>
castai · Jan 27, 2025 · 18aa0b5 · 18aa0b5
1 parent e8d2818
commit 18aa0b5
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/cmd/agent/daemon/state/netflow_pipeline.go b/cmd/agent/daemon/state/netflow_pipeline.go
@@ -61,8 +61,10 @@ func (c *Controller) runNetflowPipeline(ctx context.Context) error {
 	if err != nil {
 		c.log.Errorf("getting cluster info: %v", err)
 	}
-	c.log.Infof("fetched cluster info, pod_cidr=%s, service_cidr=%s", clusterInfo.podCidr, clusterInfo.serviceCidr)
 	c.clusterInfo = clusterInfo
+	if clusterInfo != nil {
+		c.log.Infof("fetched cluster info, pod_cidr=%s, service_cidr=%s", clusterInfo.podCidr, clusterInfo.serviceCidr)
+	}
 
 	ticker := time.NewTicker(c.cfg.NetflowExportInterval)
 	defer func() {