diff --git a/internal/datanode/channel_meta.go b/internal/datanode/channel_meta.go
index 2b314aa80d..5890975562 100644
--- a/internal/datanode/channel_meta.go
+++ b/internal/datanode/channel_meta.go
@@ -18,7 +18,6 @@ package datanode
 
 import (
 	"context"
-	"fmt"
 	"math"
 	"path"
 	"sync"
@@ -201,7 +200,7 @@ func (c *ChannelMeta) getCollectionAndPartitionID(segID UniqueID) (collID, parti
 	if seg, ok := c.segments[segID]; ok && seg.isValid() {
 		return seg.collectionID, seg.partitionID, nil
 	}
-	return 0, 0, fmt.Errorf("cannot find segment, id = %d", segID)
+	return 0, 0, merr.WrapErrSegmentNotFound(segID)
 }
 
 func (c *ChannelMeta) getChannelName() string {
@@ -640,7 +639,7 @@ func (c *ChannelMeta) getSegmentStatisticsUpdates(segID UniqueID) (*commonpb.Seg
 		return &commonpb.SegmentStats{SegmentID: segID, NumRows: seg.numRows}, nil
 	}
 
-	return nil, fmt.Errorf("error, there's no segment %d", segID)
+	return nil, merr.WrapErrSegmentNotFound(segID)
 }
 
 func (c *ChannelMeta) getCollectionID() UniqueID {