diff --git a/internal/querynodev2/pipeline/filter_policy.go b/internal/querynodev2/pipeline/filter_policy.go
index 7e12a65282..9ad7be1613 100644
--- a/internal/querynodev2/pipeline/filter_policy.go
+++ b/internal/querynodev2/pipeline/filter_policy.go
@@ -57,7 +57,7 @@ func InsertExcluded(n *filterNode, c *Collection, msg *InsertMsg) error {
 	if !ok {
 		return nil
 	}
-	if msg.EndTimestamp <= segInfo.GetDmlPosition().Timestamp {
+	if msg.EndTimestamp <= segInfo.GetDmlPosition().GetTimestamp() {
 		return WrapErrMsgExcluded(msg.SegmentID)
 	}
 	return nil
diff --git a/internal/querynodev2/pipeline/pipeline.go b/internal/querynodev2/pipeline/pipeline.go
index d72f9ca69d..8029dad870 100644
--- a/internal/querynodev2/pipeline/pipeline.go
+++ b/internal/querynodev2/pipeline/pipeline.go
@@ -44,7 +44,7 @@ func (p *pipeline) ExcludedSegments(segInfos ...*datapb.SegmentInfo) {
 	for _, segInfo := range segInfos {
 		log.Debug("pipeline add exclude info",
 			zap.Int64("segmentID", segInfo.GetID()),
-			zap.Uint64("tss", segInfo.GetDmlPosition().Timestamp),
+			zap.Uint64("ts", segInfo.GetDmlPosition().GetTimestamp()),
 		)
 		p.excludedSegments.Insert(segInfo.GetID(), segInfo)
 	}