From c162c6a4c8d15411c4ff8ce57279efaaf3acc774 Mon Sep 17 00:00:00 2001 From: "yihao.dai" Date: Sat, 16 Sep 2023 00:41:20 +0800 Subject: [PATCH] Increase FlushChannel retry times (#27140) Signed-off-by: bigsheeper --- internal/datacoord/services.go | 2 +- internal/datanode/services.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/datacoord/services.go b/internal/datacoord/services.go index 9dfb6a39b4..c4f690c3bc 100644 --- a/internal/datacoord/services.go +++ b/internal/datacoord/services.go @@ -138,7 +138,7 @@ func (s *Server) Flush(ctx context.Context, req *datapb.FlushRequest) (*datapb.F } } return nil - }) + }, retry.Attempts(20)) // about 60s if err != nil { resp.Status = merr.Status(err) return resp, nil diff --git a/internal/datanode/services.go b/internal/datanode/services.go index c7d01774fd..c4fc877d57 100644 --- a/internal/datanode/services.go +++ b/internal/datanode/services.go @@ -523,7 +523,7 @@ func (node *DataNode) Import(ctx context.Context, req *datapb.ImportTaskRequest) func (node *DataNode) FlushChannels(ctx context.Context, req *datapb.FlushChannelsRequest) (*commonpb.Status, error) { log := log.Ctx(ctx).With(zap.Int64("nodeId", paramtable.GetNodeID()), zap.Time("flushTs", tsoutil.PhysicalTime(req.GetFlushTs())), - zap.Int("len(channels)", len(req.GetChannels()))) + zap.Strings("channels", req.GetChannels())) log.Info("DataNode receives FlushChannels request")