From cfea3f43cf764a25203867f11dc96207e9803fdb Mon Sep 17 00:00:00 2001 From: "cai.zhang" Date: Thu, 6 Jun 2024 15:59:50 +0800 Subject: [PATCH] fix: Don't sync L0 segments to channel watcher (#33664) issue: #33540 Signed-off-by: Cai Zhang --- internal/datacoord/sync_segments_scheduler.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/datacoord/sync_segments_scheduler.go b/internal/datacoord/sync_segments_scheduler.go index f5224f7110..69348c0de7 100644 --- a/internal/datacoord/sync_segments_scheduler.go +++ b/internal/datacoord/sync_segments_scheduler.go @@ -115,7 +115,7 @@ func (sss *SyncSegmentsScheduler) SyncSegments(collectionID, partitionID int64, log := log.With(zap.Int64("collectionID", collectionID), zap.Int64("partitionID", partitionID), zap.String("channelName", channelName), zap.Int64("nodeID", nodeID)) segments := sss.meta.SelectSegments(WithChannel(channelName), SegmentFilterFunc(func(info *SegmentInfo) bool { - return info.GetPartitionID() == partitionID && isSegmentHealthy(info) + return info.GetPartitionID() == partitionID && isSegmentHealthy(info) && info.GetLevel() != datapb.SegmentLevel_L0 })) req := &datapb.SyncSegmentsRequest{ ChannelName: channelName,