From b7958733ad9d8df5c01890732f15245d00410df4 Mon Sep 17 00:00:00 2001 From: xzchaoo Date: Wed, 29 Nov 2023 14:51:59 +0800 Subject: [PATCH] fix: report details --- pkg/collectconfig/executor/consumer_log_sub_detail.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/collectconfig/executor/consumer_log_sub_detail.go b/pkg/collectconfig/executor/consumer_log_sub_detail.go index d487ad8..9391467 100644 --- a/pkg/collectconfig/executor/consumer_log_sub_detail.go +++ b/pkg/collectconfig/executor/consumer_log_sub_detail.go @@ -60,14 +60,14 @@ func (c *detailConsumer) MaybeFlush() { tr.Table.Rows = append(tr.Table.Rows, &pb.WriteMetricsRequestV4_Row{ Timestamp: row.Timestamp, TagValues: row.TagValues, - ValueValues: nil, + ValueValues: pbValueValues, }) } begin := time.Now() err := gateway.GetWriteService().WriteV4(context.Background(), &gateway.WriteV4Request{Batch: []*pb.WriteMetricsRequestV4_TaskResult{tr}}) sendCost := time.Since(begin) - logger.Infoz("detail", zap.Int("count", len(c.table.Rows)), zap.Duration("sendCost", sendCost), zap.Error(err)) + logger.Infoz("detail", zap.String("key", c.parent.key), zap.Int("count", len(c.table.Rows)), zap.Duration("sendCost", sendCost), zap.Error(err)) c.table = nil }