[ingester] fix query custom k8s labels

Signed-off-by: rosenlo <[email protected]>
deepflowio · Aug 25, 2023 · 3fa69f9 · 3fa69f9
1 parent 5f8e8af
commit 3fa69f9
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/server/ingester/flow_log/exporter/universal_tag.go b/server/ingester/flow_log/exporter/universal_tag.go
@@ -217,15 +217,16 @@ func (u *UniversalTagsManager) getAuto(autoType DeviceType, autoID uint32, isIPv
 }
 
 func (u *UniversalTagsManager) QueryCustomK8sLabels(podID uint32) Labels {
-	return u.podIDLabelsMap[podID]
+	return u.universalTagMaps.podK8SLabelMap[podID]
 }
 
 type UniversalTagsManager struct {
 	config           *config.Config
 	universalTagMaps *UniversalTagMaps
 	tapPortNameMap   map[uint64]string
-	podIDLabelsMap   map[uint32]Labels
-	k8sLabelsRegexp  *regexp.Regexp
+	// Deprecated
+	podIDLabelsMap  map[uint32]Labels
+	k8sLabelsRegexp *regexp.Regexp
 
 	connection              *sql.DB
 	grpcSession             *grpc.GrpcSession