diff --git a/internal/datacoord/meta.go b/internal/datacoord/meta.go
index 3ae2164079..3eb2274ac6 100644
--- a/internal/datacoord/meta.go
+++ b/internal/datacoord/meta.go
@@ -439,7 +439,7 @@ func (m *meta) mergeDropSegment(seg2Drop *SegmentInfo) *SegmentInfo {
 // ** the removal flag is always with last batch
 // ** the last batch must contains at least one segment
 // 1. when failure occurs between batches, failover mechanism will continue with the earlist  checkpoint of this channel
-//   since the flag is not marked so data node can re-consume the drop collection msg
+//   since the flag is not marked so DataNode can re-consume the drop collection msg
 // 2. when failure occurs between save meta and unwatch channel, the removal flag shall be check before let datanode  watch this channel
 func (m *meta) batchSaveDropSegments(channel string, modSegments map[int64]*SegmentInfo) error {