mirror of
https://gitee.com/milvus-io/milvus.git
synced 2025-12-07 01:28:27 +08:00
enhance: Remove unnecessary segment clone updating dist (#37797)
Related to #37630 Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
This commit is contained in:
parent
484c6b5c44
commit
b8d31ebed8
3
internal/querycoordv2/dist/dist_handler.go
vendored
3
internal/querycoordv2/dist/dist_handler.go
vendored
@ -24,7 +24,6 @@ import (
|
|||||||
|
|
||||||
"github.com/samber/lo"
|
"github.com/samber/lo"
|
||||||
"go.uber.org/zap"
|
"go.uber.org/zap"
|
||||||
"google.golang.org/protobuf/proto"
|
|
||||||
|
|
||||||
"github.com/milvus-io/milvus-proto/go-api/v2/commonpb"
|
"github.com/milvus-io/milvus-proto/go-api/v2/commonpb"
|
||||||
"github.com/milvus-io/milvus/internal/proto/datapb"
|
"github.com/milvus-io/milvus/internal/proto/datapb"
|
||||||
@ -156,7 +155,7 @@ func (dh *distHandler) updateSegmentsDistribution(resp *querypb.GetDataDistribut
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
updates = append(updates, &meta.Segment{
|
updates = append(updates, &meta.Segment{
|
||||||
SegmentInfo: proto.Clone(segmentInfo).(*datapb.SegmentInfo),
|
SegmentInfo: segmentInfo,
|
||||||
Node: resp.GetNodeID(),
|
Node: resp.GetNodeID(),
|
||||||
Version: s.GetVersion(),
|
Version: s.GetVersion(),
|
||||||
LastDeltaTimestamp: s.GetLastDeltaTimestamp(),
|
LastDeltaTimestamp: s.GetLastDeltaTimestamp(),
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user