From 12b3a29db88e14f76e1fec2e9f2a574ac81ac2de Mon Sep 17 00:00:00 2001 From: congqixia Date: Mon, 20 Jun 2022 13:40:12 +0800 Subject: [PATCH] Fix segments info in drop virtual channel request is not set (#17641) Signed-off-by: Congqi Xia --- internal/datanode/flush_manager.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/internal/datanode/flush_manager.go b/internal/datanode/flush_manager.go index 46095c64f2..973289fca4 100644 --- a/internal/datanode/flush_manager.go +++ b/internal/datanode/flush_manager.go @@ -679,6 +679,13 @@ func dropVirtualChannelFunc(dsService *dataSyncService, opts ...retry.Option) fl segment.StartPosition = pos.GetStartPosition() } + // assign segments to request + segments := make([]*datapb.DropVirtualChannelSegment, 0, len(segmentPack)) + for _, segment := range segmentPack { + segments = append(segments, segment) + } + req.Segments = segments + err := retry.Do(context.Background(), func() error { rsp, err := dsService.dataCoord.DropVirtualChannel(context.Background(), req) // should be network issue, return error and retry