diff --git a/internal/datacoord/server.go b/internal/datacoord/server.go
index 9d8c9b3379..e1c6fad719 100644
--- a/internal/datacoord/server.go
+++ b/internal/datacoord/server.go
@@ -426,7 +426,9 @@ func (s *Server) startDataNodeTtLoop(ctx context.Context) {
 				}
 
 				staleSegments := s.meta.SelectSegments(func(info *SegmentInfo) bool {
-					return !info.lastFlushTime.IsZero() && time.Since(info.lastFlushTime).Minutes() >= segmentTimedFlushDuration
+					return info.GetInsertChannel() == ch &&
+						!info.lastFlushTime.IsZero() &&
+						time.Since(info.lastFlushTime).Minutes() >= segmentTimedFlushDuration
 				})
 
 				if len(segments)+len(staleSegments) == 0 {