From 0b2c0fb2614f314af097a772d372f5abeaec81ad Mon Sep 17 00:00:00 2001 From: congqixia Date: Tue, 21 Dec 2021 15:38:20 +0800 Subject: [PATCH] [skip e2e] Remove commented unused code (#13843) Signed-off-by: Congqi Xia --- internal/datacoord/services.go | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/internal/datacoord/services.go b/internal/datacoord/services.go index f09720d71a..c62d71ddb6 100644 --- a/internal/datacoord/services.go +++ b/internal/datacoord/services.go @@ -364,17 +364,6 @@ func (s *Server) SaveBinlogPaths(ctx context.Context, req *datapb.SaveBinlogPath log.Debug("flush segment with meta", zap.Int64("id", req.SegmentID), zap.Any("meta", req.GetField2BinlogPaths())) - // Drop logic handler in DropVirtualChannel - /* - if req.GetDropped() && s.handler.CheckShouldDropChannel(channel) { - log.Debug("remove channel", zap.String("channel", channel)) - err = s.channelManager.RemoveChannel(channel) - if err != nil { - log.Warn("failed to remove channel", zap.String("channel", channel), zap.Error(err)) - } - s.segmentManager.DropSegmentsOfChannel(ctx, channel) - }*/ - if req.GetFlushed() { s.segmentManager.DropSegment(ctx, req.SegmentID) s.flushCh <- req.SegmentID