未验证 提交 49b6c310 编写于 作者: S sunby 提交者: GitHub

Remove datacoord useless code (#7673)

Issue: #7624
Signed-off-by: Nsunby <bingyi.sun@zilliz.com>
上级 624ea2f6
......@@ -147,7 +147,6 @@ func TestMeta_Basic(t *testing.T) {
t.Run("Test GetCount", func(t *testing.T) {
const rowCount0 = 100
const rowCount1 = 300
const dim = 1024
// no segment
nums := meta.GetNumRowsOfCollection(collID)
......
......@@ -79,8 +79,6 @@ func AllocatePolicyV1(segments []*SegmentInfo, count int64,
return newSegmentAllocations, existedSegmentAllocations
}
type sealPolicy func(maxCount, writtenCount, allocatedCount int64) bool
// segmentSealPolicy seal policy applies to segment
type segmentSealPolicy func(segment *SegmentInfo, ts Timestamp) bool
......
......@@ -41,11 +41,7 @@ import (
"github.com/milvus-io/milvus/internal/proto/milvuspb"
)
const (
rootCoordClientTimout = 20 * time.Second
connEtcdMaxRetryTime = 100000
connEtcdRetryInterval = 200 * time.Millisecond
)
const connEtcdMaxRetryTime = 100000
var (
// TODO: sunby put to config
......@@ -95,7 +91,6 @@ type Server struct {
allocator allocator
cluster *Cluster
rootCoordClient types.RootCoord
ddChannelName string
metricsCacheManager *metricsinfo.MetricsCacheManager
......
......@@ -61,7 +61,6 @@ func TestAssignSegmentID(t *testing.T) {
const collIDInvalid = 101
const partID = 0
const channel0 = "channel0"
const channel1 = "channel1"
t.Run("assign segment normally", func(t *testing.T) {
svr := newTestServer(t, nil)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册