From 3fa69f93700392f053608bd6cec5acf409ee09a0 Mon Sep 17 00:00:00 2001 From: rosenlo Date: Thu, 17 Aug 2023 22:09:31 +0800 Subject: [PATCH] [ingester] fix query custom k8s labels Signed-off-by: rosenlo --- server/ingester/flow_log/exporter/universal_tag.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/server/ingester/flow_log/exporter/universal_tag.go b/server/ingester/flow_log/exporter/universal_tag.go index 02ab45a2b72..746a7345be9 100644 --- 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