From d6e50972c7c00875dedceb51fb41a32a1e8934bd Mon Sep 17 00:00:00 2001 From: zhuofeng Date: Sat, 12 Oct 2024 09:34:24 +0800 Subject: [PATCH] fix: add export thread id Prevent data with the same Tag from being exported --- server/libs/flow-metrics/tag.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/server/libs/flow-metrics/tag.go b/server/libs/flow-metrics/tag.go index b47045ecda8..fd725d657c8 100644 --- a/server/libs/flow-metrics/tag.go +++ b/server/libs/flow-metrics/tag.go @@ -256,7 +256,7 @@ type Field struct { // 用于区分不同的trident及其不同的pipeline，用于如下场景： // - agent和ingester之间的数据传输 // - ingester写入clickhouse，作用类似_id，序列化为_tid - GlobalThreadID uint8 + GlobalThreadID uint8 `json:"thread_id" category:"$tag"` // structTag "datasource":"n|nm|a|am" means datasource: network, network_map, application, application_map IP6 net.IP `json:"ip6" map_json:"ip6_0" category:"$tag" sub:"network_layer" to_string:"IPv6String" ` // FIXME: 合并IP6和IP @@ -1343,6 +1343,7 @@ func (t *Tag) String() string { func (t *Tag) ReadFromPB(p *pb.MiniTag) { t.Code = Code(p.Code) + t.GlobalThreadID = uint8(p.Field.GlobalThreadId) t.IsIPv4 = 1 - uint8(p.Field.IsIpv6) if t.IsIPv4 == 0 { if t.IP6 == nil {