From 970dcb3161a8a19fa042dc589d972d84e9105945 Mon Sep 17 00:00:00 2001 From: aoiasd <45024769+aoiasd@users.noreply.github.com> Date: Wed, 29 Mar 2023 17:20:04 +0800 Subject: [PATCH] Fix panic because timestamp was nil (#23096) Signed-off-by: aoiasd --- internal/querynodev2/pipeline/filter_policy.go | 2 +- internal/querynodev2/pipeline/pipeline.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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) }