Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
milvus
milvus
提交
ef3b71f2
M
milvus
项目概览
milvus
/
milvus
大约 1 年 前同步成功
通知
261
Star
22476
Fork
2472
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
M
milvus
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
未验证
提交
ef3b71f2
编写于
12月 22, 2021
作者:
C
congqixia
提交者:
GitHub
12月 22, 2021
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Use indexInfo SerializedSize when estimating segment size (#13969)
Signed-off-by:
N
Congqi Xia
<
congqi.xia@zilliz.com
>
上级
da5a7407
变更
5
隐藏空白更改
内联
并排
Showing
5 changed file
with
82 addition
and
83 deletion
+82
-83
internal/indexcoord/meta_table.go
internal/indexcoord/meta_table.go
+1
-0
internal/proto/index_coord.proto
internal/proto/index_coord.proto
+1
-0
internal/proto/indexpb/index_coord.pb.go
internal/proto/indexpb/index_coord.pb.go
+75
-66
internal/querycoord/cluster.go
internal/querycoord/cluster.go
+1
-15
internal/querycoord/cluster_test.go
internal/querycoord/cluster_test.go
+4
-2
未找到文件。
internal/indexcoord/meta_table.go
浏览文件 @
ef3b71f2
...
...
@@ -316,6 +316,7 @@ func (mt *metaTable) GetIndexFilePathInfo(indexBuildID UniqueID) (*indexpb.Index
return
nil
,
fmt
.
Errorf
(
"index not exists with ID = %d"
,
indexBuildID
)
}
ret
.
IndexFilePaths
=
meta
.
indexMeta
.
IndexFilePaths
ret
.
SerializedSize
=
meta
.
indexMeta
.
GetSerializeSize
()
return
ret
,
nil
}
...
...
internal/proto/index_coord.proto
浏览文件 @
ef3b71f2
...
...
@@ -95,6 +95,7 @@ message IndexFilePathInfo {
common.Status
status
=
1
;
int64
indexBuildID
=
2
;
repeated
string
index_file_paths
=
3
;
uint64
serialized_size
=
4
;
}
message
GetIndexFilePathsResponse
{
...
...
internal/proto/indexpb/index_coord.pb.go
浏览文件 @
ef3b71f2
...
...
@@ -567,6 +567,7 @@ type IndexFilePathInfo struct {
Status
*
commonpb
.
Status
`protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
IndexBuildID
int64
`protobuf:"varint,2,opt,name=indexBuildID,proto3" json:"indexBuildID,omitempty"`
IndexFilePaths
[]
string
`protobuf:"bytes,3,rep,name=index_file_paths,json=indexFilePaths,proto3" json:"index_file_paths,omitempty"`
SerializedSize
uint64
`protobuf:"varint,4,opt,name=serialized_size,json=serializedSize,proto3" json:"serialized_size,omitempty"`
XXX_NoUnkeyedLiteral
struct
{}
`json:"-"`
XXX_unrecognized
[]
byte
`json:"-"`
XXX_sizecache
int32
`json:"-"`
...
...
@@ -618,6 +619,13 @@ func (m *IndexFilePathInfo) GetIndexFilePaths() []string {
return
nil
}
func
(
m
*
IndexFilePathInfo
)
GetSerializedSize
()
uint64
{
if
m
!=
nil
{
return
m
.
SerializedSize
}
return
0
}
type
GetIndexFilePathsResponse
struct
{
Status
*
commonpb
.
Status
`protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
FilePaths
[]
*
IndexFilePathInfo
`protobuf:"bytes,2,rep,name=file_paths,json=filePaths,proto3" json:"file_paths,omitempty"`
...
...
@@ -834,73 +842,74 @@ func init() {
func
init
()
{
proto
.
RegisterFile
(
"index_coord.proto"
,
fileDescriptor_f9e019eb3fda53c2
)
}
var
fileDescriptor_f9e019eb3fda53c2
=
[]
byte
{
// 10
57
bytes of a gzipped FileDescriptorProto
// 10
73
bytes of a gzipped FileDescriptorProto
0x1f
,
0x8b
,
0x08
,
0x00
,
0x00
,
0x00
,
0x00
,
0x00
,
0x02
,
0xff
,
0xec
,
0x56
,
0xcd
,
0x6e
,
0xdb
,
0x46
,
0x10
,
0x36
,
0x4d
,
0x5b
,
0x3f
,
0x23
,
0xc5
,
0x88
,
0xb7
,
0x69
,
0xc0
,
0x28
,
0x0d
,
0x22
,
0xb3
,
0x49
,
0xaa
,
0x16
,
0x89
,
0x1c
,
0x28
,
0x4d
,
0x7b
,
0x2a
,
0xd0
,
0xda
,
0x42
,
0x0c
,
0xa3
,
0x70
,
0x60
,
0xac
,
0x8d
,
0x1e
,
0x0a
,
0x14
,
0xc2
,
0x5a
,
0x1c
,
0xd9
,
0x8b
,
0xf0
,
0x47
,
0xe6
,
0xae
,
0x92
,
0xda
,
0xc7
,
0xa2
,
0xf7
,
0xde
,
0xd2
,
0x47
,
0xe9
,
0x73
,
0xe4
,
0x71
,
0x7a
,
0x2b
,
0x76
,
0xb9
,
0xa4
,
0x49
,
0x89
,
0x72
,
0xe4
,
0xba
,
0x69
,
0x2f
,
0xbd
,
0x71
,
0x86
,
0xdf
,
0xec
,
0xec
,
0x7c
,
0x3b
,
0xf3
,
0xed
,
0xc2
,
0x3a
,
0x0f
,
0x3d
,
0xfc
,
0x79
,
0x30
,
0x8c
,
0xa2
,
0xd8
,
0xeb
,
0x8e
,
0xe3
,
0x48
,
0x46
,
0x84
,
0x04
,
0xdc
,
0x7f
,
0x3d
,
0x11
,
0x89
,
0xd5
,
0xd5
,
0xff
,
0x5b
,
0xcd
,
0x61
,
0x14
,
0x04
,
0x51
,
0x98
,
0xf8
,
0x5a
,
0x6b
,
0x3c
,
0x94
,
0x18
,
0x87
,
0xcc
,
0x37
,
0x76
,
0x33
,
0x1f
,
0xd1
,
0x6a
,
0x8a
,
0xe1
,
0x09
,
0x06
,
0x2c
,
0xb1
,
0xdc
,
0xdf
,
0x2d
,
0xf8
,
0x88
,
0xe2
,
0x31
,
0x17
,
0x12
,
0xe3
,
0x97
,
0x91
,
0x87
,
0x14
,
0x4f
,
0x27
,
0x28
,
0x24
,
0x79
,
0x0a
,
0x2b
,
0x47
,
0x4c
,
0xa0
,
0x63
,
0xb5
,
0xad
,
0x4e
,
0xa3
,
0xf7
,
0x49
,
0xb7
,
0x90
,
0xd4
,
0x64
,
0xdb
,
0x13
,
0xc7
,
0x5b
,
0x4c
,
0x20
,
0xd5
,
0x48
,
0xf2
,
0x15
,
0x54
,
0x99
,
0xe7
,
0xc5
,
0x28
,
0x84
,
0xb3
,
0x7c
,
0x49
,
0xd0
,
0x77
,
0x09
,
0x86
,
0xa6
,
0x60
,
0x72
,
0x1b
,
0x2a
,
0x61
,
0xe4
,
0xe1
,
0x6e
,
0xdf
,
0xb1
,
0xdb
,
0x56
,
0xc7
,
0xa6
,
0xc6
,
0x72
,
0x7f
,
0xb3
,
0xe0
,
0x56
,
0x71
,
0x67
,
0x62
,
0x1c
,
0x85
,
0x02
,
0xc9
,
0x33
,
0xa8
,
0x08
,
0xc9
,
0xe4
,
0x44
,
0x98
,
0xcd
,
0xdd
,
0x2d
,
0xcd
,
0x73
,
0xa0
,
0x21
,
0xd4
,
0x40
,
0xc9
,
0x16
,
0x34
,
0x78
,
0xc8
,
0xe5
,
0x60
,
0xcc
,
0x62
,
0x16
,
0xa4
,
0x3b
,
0xdc
,
0xe8
,
0x4e
,
0x71
,
0x69
,
0x68
,
0xdb
,
0x0d
,
0xb9
,
0xdc
,
0xd7
,
0x40
,
0x0a
,
0x3c
,
0xfb
,
0x76
,
0xbf
,
0x81
,
0x8f
,
0x77
,
0x50
,
0xee
,
0x2a
,
0xc6
,
0xd5
,
0xea
,
0x28
,
0x52
,
0xb2
,
0x1e
,
0xc0
,
0x0d
,
0x7d
,
0x0e
,
0x5b
,
0x13
,
0xee
,
0x7b
,
0xbb
,
0x7d
,
0xb5
,
0x31
,
0xbb
,
0x63
,
0xd3
,
0xa2
,
0xd3
,
0xfd
,
0xc3
,
0x82
,
0xba
,
0x0e
,
0xde
,
0x0d
,
0x47
,
0x11
,
0x79
,
0x0e
,
0xab
,
0x6a
,
0x6b
,
0x09
,
0xc3
,
0x6b
,
0xbd
,
0xfb
,
0xa5
,
0x45
,
0x5c
,
0xe4
,
0xa2
,
0x09
,
0x9a
,
0xb8
,
0xd0
,
0xcc
,
0xaf
,
0xaa
,
0x0b
,
0xb1
,
0x69
,
0xc1
,
0x47
,
0x1c
,
0xa8
,
0x6a
,
0x3b
,
0xa3
,
0x34
,
0x35
,
0xc9
,
0x3d
,
0x80
,
0xa4
,
0xa1
,
0x42
,
0x16
,
0xa0
,
0xb3
,
0xd2
,
0xb6
,
0x3a
,
0x75
,
0x5a
,
0xd7
,
0x9e
,
0x97
,
0x2c
,
0x40
,
0x75
,
0x14
,
0x31
,
0x32
,
0x11
,
0x85
,
0xce
,
0xaa
,
0xfe
,
0x65
,
0x2c
,
0xf7
,
0x57
,
0x0b
,
0x6e
,
0x4f
,
0x57
,
0x7e
,
0x9d
,
0xc3
,
0x78
,
0x9e
,
0x04
,
0xa1
,
0x3a
,
0x07
,
0xbb
,
0xd3
,
0xe8
,
0xdd
,
0xeb
,
0xce
,
0xf6
,
0x74
,
0x37
,
0xa3
,
0x8a
,
0x1a
,
0xb0
,
0xfb
,
0x6e
,
0x19
,
0xc8
,
0x76
,
0x8c
,
0x4c
,
0xa2
,
0xfe
,
0x97
,
0xb2
,
0x3f
,
0x4d
,
0x89
,
0x55
,
0x42
,
0x49
,
0xb1
,
0xf0
,
0xe5
,
0xe9
,
0xc2
,
0xe7
,
0x33
,
0xe6
,
0x40
,
0xf5
,
0x35
,
0xc6
,
0x82
,
0x47
,
0xa1
,
0xa6
,
0xcb
,
0xa6
,
0xa9
,
0x49
,
0xee
,
0x42
,
0x3d
,
0x40
,
0xc9
,
0x06
,
0x63
,
0x26
,
0x4f
,
0x0c
,
0x5f
,
0x35
,
0xe5
,
0xd8
,
0x67
,
0xf2
,
0x44
,
0xe5
,
0xf3
,
0x98
,
0xf9
,
0x29
,
0x9c
,
0x4a
,
0xdb
,
0x56
,
0xf9
,
0x94
,
0x47
,
0xfd
,
0xd5
,
0xdd
,
0x28
,
0xcf
,
0xc6
,
0x98
,
0x76
,
0x63
,
0x55
,
0xb3
,
0xb0
,
0x51
,
0x4a
,
0xdd
,
0xf7
,
0x78
,
0xf6
,
0x03
,
0xf3
,
0x27
,
0xb8
,
0xcf
,
0x78
,
0x4c
,
0x41
,
0x45
,
0x25
,
0xdd
,
0x48
,
0xfa
,
0xa6
,
0xec
,
0x74
,
0x91
,
0xda
,
0xa2
,
0x8b
,
0x34
,
0x74
,
0x98
,
0xe9
,
0xe9
,
0x3f
,
0x97
,
0x61
,
0x3d
,
0x21
,
0xe9
,
0x5f
,
0xa3
,
0xb4
,
0xc8
,
0xcd
,
0xea
,
0x7b
,
0xb8
,
0xa9
,
0xfc
,
0x13
,
0xdc
,
0x54
,
0xff
,
0x0e
,
0x37
,
0xe4
,
0x0e
,
0xd4
,
0xc2
,
0x49
,
0x30
,
0x88
,
0xa3
,
0x37
,
0x8a
,
0x5d
,
0x5d
,
0x43
,
0x38
,
0x09
,
0x68
,
0xf4
,
0x46
,
0x90
,
0x6d
,
0x68
,
0x8e
,
0x38
,
0xfa
,
0xde
,
0x20
,
0x11
,
0x53
,
0xa7
,
0xae
,
0x9b
,
0xbf
,
0x5d
,
0x4c
,
0x60
,
0x84
,
0xf6
,
0x85
,
0x02
,
0x1e
,
0xe8
,
0x6f
,
0xda
,
0x18
,
0x5d
,
0x18
,
0x6e
,
0x00
,
0x24
,
0x4f
,
0xfd
,
0x75
,
0x26
,
0x6a
,
0x01
,
0x59
,
0x70
,
0xbf
,
0x05
,
0x27
,
0x1d
,
0xe2
,
0x17
,
0xdc
,
0x47
,
0xcd
,
0xf6
,
0xd5
,
0x14
,
0xec
,
0xad
,
0x05
,
0xeb
,
0x85
,
0x78
,
0xad
,
0x64
,
0x1f
,
0x6a
,
0xc3
,
0xa4
,
0x03
,
0x37
,
0x93
,
0x53
,
0x1c
,
0x71
,
0x1f
,
0x4d
,
0xbb
,
0xd8
,
0xba
,
0x5d
,
0xd6
,
0x78
,
0xa1
,
0x0a
,
0xb5
,
0xb1
,
0x3b
,
0x25
,
0xb5
,
0x5d
,
0x87
,
0xd1
,
0x3e
,
0x40
,
0x2e
,
0x6d
,
0xa2
,
0x53
,
0x0f
,
0xe7
,
0xea
,
0x54
,
0x9e
,
0x10
,
0x5a
,
0x1f
,
0x65
,
0x1b
,
0xfb
,
0xc5
,
0x36
,
0x9a
,
0xbf
,
0x87
,
0x92
,
0x2d
,
0x34
,
0x56
,
0xd9
,
0xbd
,
0xb0
,
0x7c
,
0xa5
,
0x7b
,
0xe1
,
0x3e
,
0x34
,
0x46
,
0x8c
,
0xfb
,
0x03
,
0xa3
,
0xdf
,
0xb6
,
0x1e
,
0x47
,
0x50
,
0x2e
,
0xaa
,
0x3d
,
0xe4
,
0x6b
,
0xb0
,
0x63
,
0x3c
,
0xd5
,
0x22
,
0x36
,
0xa7
,
0x90
,
0x19
,
0x19
,
0xa0
,
0x2a
,
0xa2
,
0xf4
,
0x14
,
0x56
,
0xcb
,
0x4e
,
0x81
,
0x6c
,
0x40
,
0x33
,
0x60
,
0xf1
,
0xab
,
0x81
,
0x87
,
0x3e
,
0x4a
,
0xf4
,
0x9c
,
0x4a
,
0xdb
,
0xea
,
0xd4
,
0x68
,
0x43
,
0xf9
,
0xfa
,
0x89
,
0x2b
,
0x77
,
0xd9
,
0x57
,
0xf3
,
0x97
,
0x7d
,
0x5e
,
0x66
,
0x6b
,
0x45
,
0x99
,
0x6d
,
0x41
,
0x2d
,
0xc6
,
0xe1
,
0xd9
,
0xd0
,
0x47
,
0x4f
,
0x4f
,
0x59
,
0x8d
,
0x66
,
0x36
,
0x79
,
0x08
,
0x6b
,
0x02
,
0x63
,
0xce
,
0x7c
,
0x7e
,
0x8e
,
0x03
,
0xc1
,
0xcf
,
0xd1
,
0x81
,
0xb6
,
0xd5
,
0x59
,
0xa1
,
0x37
,
0x32
,
0xef
,
0x01
,
0x3f
,
0x47
,
0xf7
,
0x31
,
0xdc
,
0xec
,
0xc7
,
0xd1
,
0xb8
,
0xa0
,
0x70
,
0x39
,
0x79
,
0xb2
,
0x0a
,
0xf2
,
0xd4
,
0x7b
,
0x57
,
0x01
,
0xd0
,
0xd0
,
0x6d
,
0xf5
,
0xe8
,
0x22
,
0x63
,
0x20
,
0x3b
,
0x28
,
0xb7
,
0xa3
,
0x60
,
0x1c
,
0x85
,
0x18
,
0xca
,
0xe4
,
0xfa
,
0x23
,
0x4f
,
0xe7
,
0xbc
,
0x1c
,
0x66
,
0xa1
,
0x26
,
0x61
,
0xeb
,
0xd1
,
0x9c
,
0x88
,
0x29
,
0xb8
,
0xbb
,
0x44
,
0x02
,
0x9d
,
0xf1
,
0x90
,
0x07
,
0x78
,
0xc8
,
0x87
,
0xaf
,
0xb6
,
0x4f
,
0x58
,
0x18
,
0xa2
,
0x7f
,
0x59
,
0xc6
,
0x29
,
0x68
,
0x9a
,
0xf1
,
0xd3
,
0x62
,
0x84
,
0x31
,
0x0e
,
0x64
,
0xcc
,
0xc3
,
0xe3
,
0x74
,
0x36
,
0xdc
,
0x25
,
0x72
,
0x0a
,
0xb7
,
0x76
,
0x50
,
0x67
,
0xe7
,
0x42
,
0xf2
,
0xa1
,
0x48
,
0x13
,
0xf6
,
0xe6
,
0x27
,
0x9c
,
0x01
,
0x5f
,
0x31
,
0xe5
,
0x4f
,
0x00
,
0x17
,
0xcd
,
0x46
,
0x16
,
0x6b
,
0xc6
,
0x59
,
0x02
,
0xa7
,
0x61
,
0xd9
,
0xf2
,
0x1c
,
0xd6
,
0x8a
,
0xaf
,
0x15
,
0xf2
,
0x79
,
0x59
,
0x6c
,
0xe9
,
0x5b
,
0xae
,
0xf5
,
0xc5
,
0x22
,
0xd0
,
0x2c
,
0x55
,
0x0c
,
0xeb
,
0x33
,
0xba
,
0x43
,
0x1e
,
0x5f
,
0xb6
,
0xc4
,
0xb4
,
0xf4
,
0xb6
,
0x9e
,
0x2c
,
0x88
,
0xce
,
0x72
,
0xee
,
0x43
,
0x3d
,
0x6b
,
0x67
,
0xf2
,
0xa0
,
0x2c
,
0x7a
,
0xba
,
0xdb
,
0x5b
,
0x97
,
0x29
,
0x9e
,
0xbb
,
0x44
,
0x06
,
0x00
,
0x3b
,
0x28
,
0xf7
,
0x50
,
0xc6
,
0x7c
,
0x28
,
0xc8
,
0xa3
,
0xd2
,
0x43
,
0xbc
,
0x00
,
0xa4
,
0x8b
,
0x7e
,
0xf6
,
0x5e
,
0x5c
,
0xba
,
0xe5
,
0xde
,
0xdb
,
0x15
,
0x23
,
0x83
,
0xea
,
0x21
,
0xff
,
0xff
,
0x48
,
0x7d
,
0x80
,
0x91
,
0x3a
,
0x84
,
0x46
,
0xee
,
0x69
,
0x4c
,
0x4a
,
0x87
,
0x65
,
0xf6
,
0xed
,
0xfc
,
0x5f
,
0x37
,
0xc6
,
0xd6
,
0x97
,
0x3f
,
0xf6
,
0x8e
,
0xb9
,
0x3c
,
0x99
,
0x1c
,
0xa9
,
0xd4
,
0x9b
,
0x09
,
0xf2
,
0x09
,
0x8f
,
0xcc
,
0xd7
,
0x66
,
0xca
,
0xd0
,
0xa6
,
0x5e
,
0x69
,
0x53
,
0x97
,
0x31
,
0x3e
,
0x3a
,
0xaa
,
0x68
,
0xf3
,
0xd9
,
0x5f
,
0x01
,
0x00
,
0x00
,
0xff
,
0xff
,
0x1b
,
0x2b
,
0xc8
,
0x1a
,
0x1e
,
0x0f
,
0x00
,
0x10
,
0x36
,
0x4d
,
0x5b
,
0x3f
,
0x23
,
0xc5
,
0x8d
,
0xb7
,
0x69
,
0xc0
,
0x28
,
0x0d
,
0x22
,
0xb3
,
0xf9
,
0x51
,
0x8b
,
0x44
,
0x0e
,
0x94
,
0xa6
,
0x3d
,
0x15
,
0x68
,
0x6d
,
0x21
,
0x86
,
0x51
,
0x38
,
0x30
,
0xd6
,
0x46
,
0x0f
,
0x05
,
0x0a
,
0x61
,
0x2d
,
0x8e
,
0xec
,
0x45
,
0xf8
,
0x23
,
0x73
,
0x57
,
0x49
,
0xed
,
0x63
,
0xd1
,
0x7b
,
0x6f
,
0xe9
,
0xa3
,
0xf4
,
0xd8
,
0x67
,
0xc8
,
0xe3
,
0xf4
,
0x56
,
0xec
,
0x72
,
0x29
,
0x91
,
0x12
,
0xe5
,
0xc8
,
0x75
,
0xd3
,
0x5e
,
0x72
,
0xe3
,
0xcc
,
0x7e
,
0xb3
,
0xb3
,
0xf3
,
0xed
,
0xec
,
0xc7
,
0x81
,
0x75
,
0x1e
,
0x7a
,
0xf8
,
0x73
,
0xaf
,
0x1f
,
0x45
,
0xb1
,
0xd7
,
0x1e
,
0xc6
,
0x91
,
0x8c
,
0x08
,
0x09
,
0xb8
,
0xff
,
0x6a
,
0x24
,
0x12
,
0xab
,
0xad
,
0xd7
,
0x1b
,
0xf5
,
0x7e
,
0x14
,
0x04
,
0x51
,
0x98
,
0xf8
,
0x1a
,
0x6b
,
0x3c
,
0x94
,
0x18
,
0x87
,
0xcc
,
0x37
,
0x76
,
0x3d
,
0x1b
,
0xd1
,
0xa8
,
0x8b
,
0xfe
,
0x09
,
0x06
,
0x2c
,
0xb1
,
0xdc
,
0xdf
,
0x2d
,
0xf8
,
0x98
,
0xe2
,
0x31
,
0x17
,
0x12
,
0xe3
,
0x17
,
0x91
,
0x87
,
0x14
,
0x4f
,
0x47
,
0x28
,
0x24
,
0x79
,
0x02
,
0x2b
,
0x47
,
0x4c
,
0xa0
,
0x63
,
0x35
,
0xad
,
0x56
,
0xad
,
0xf3
,
0x69
,
0x3b
,
0x97
,
0xd4
,
0x64
,
0xdb
,
0x13
,
0xc7
,
0x5b
,
0x4c
,
0x20
,
0xd5
,
0x48
,
0xf2
,
0x15
,
0x94
,
0x99
,
0xe7
,
0xc5
,
0x28
,
0x84
,
0xb3
,
0x7c
,
0x41
,
0xd0
,
0x77
,
0x09
,
0x86
,
0xa6
,
0x60
,
0x72
,
0x13
,
0x4a
,
0x61
,
0xe4
,
0xe1
,
0x6e
,
0xd7
,
0xb1
,
0x9b
,
0x56
,
0xcb
,
0xa6
,
0xc6
,
0x72
,
0x7f
,
0xb3
,
0xe0
,
0x46
,
0xfe
,
0x64
,
0x62
,
0x18
,
0x85
,
0x02
,
0xc9
,
0x53
,
0x28
,
0x09
,
0xc9
,
0xe4
,
0x48
,
0x98
,
0xc3
,
0xdd
,
0x2e
,
0xcc
,
0x73
,
0xa0
,
0x21
,
0xd4
,
0x40
,
0xc9
,
0x16
,
0xd4
,
0x78
,
0xc8
,
0x65
,
0x6f
,
0xc8
,
0x62
,
0x16
,
0xa4
,
0x27
,
0xdc
,
0x68
,
0x4f
,
0x71
,
0x69
,
0x68
,
0xdb
,
0x0d
,
0xb9
,
0xdc
,
0xd7
,
0x40
,
0x0a
,
0x7c
,
0xfc
,
0xed
,
0x7e
,
0x03
,
0x9f
,
0xec
,
0xa0
,
0xdc
,
0x55
,
0x8c
,
0xab
,
0xdd
,
0x51
,
0xa4
,
0x64
,
0xdd
,
0x83
,
0x6b
,
0xfa
,
0x1e
,
0xb6
,
0x46
,
0xdc
,
0xf7
,
0x76
,
0xbb
,
0xea
,
0x60
,
0x76
,
0xcb
,
0xa6
,
0x79
,
0xa7
,
0xfb
,
0x87
,
0x05
,
0x55
,
0x1d
,
0xbc
,
0x1b
,
0x0e
,
0x22
,
0xf2
,
0x0c
,
0x56
,
0xd5
,
0xd1
,
0x12
,
0x86
,
0xd7
,
0x3a
,
0x77
,
0x0b
,
0x8b
,
0x98
,
0xe4
,
0xa2
,
0x09
,
0x9a
,
0xb8
,
0x50
,
0xcf
,
0xee
,
0xaa
,
0x0b
,
0xb1
,
0x69
,
0xce
,
0x47
,
0x1c
,
0x28
,
0x6b
,
0x7b
,
0x4c
,
0x69
,
0x6a
,
0x92
,
0x3b
,
0x00
,
0x49
,
0x43
,
0x85
,
0x2c
,
0x40
,
0x67
,
0xa5
,
0x69
,
0xb5
,
0xaa
,
0xb4
,
0xaa
,
0x3d
,
0x2f
,
0x58
,
0x80
,
0xea
,
0x2a
,
0x62
,
0x64
,
0x22
,
0x0a
,
0x9d
,
0x55
,
0xbd
,
0x64
,
0x2c
,
0xf7
,
0x57
,
0x0b
,
0x6e
,
0x4e
,
0x57
,
0x7e
,
0x95
,
0xcb
,
0x78
,
0x96
,
0x04
,
0xa1
,
0xba
,
0x07
,
0xbb
,
0x55
,
0xeb
,
0xdc
,
0x69
,
0xcf
,
0xf6
,
0x74
,
0x7b
,
0x4c
,
0x15
,
0x35
,
0x60
,
0xf7
,
0xed
,
0x32
,
0x90
,
0xed
,
0x18
,
0x99
,
0x44
,
0xbd
,
0x96
,
0xb2
,
0x3f
,
0x4d
,
0x89
,
0x55
,
0x40
,
0x49
,
0xbe
,
0xf0
,
0xe5
,
0xe9
,
0xc2
,
0xe7
,
0x33
,
0xe6
,
0x40
,
0xf9
,
0x15
,
0xc6
,
0x82
,
0x47
,
0xa1
,
0xa6
,
0xcb
,
0xa6
,
0xa9
,
0x49
,
0x6e
,
0x43
,
0x35
,
0x40
,
0xc9
,
0x7a
,
0x43
,
0x26
,
0x4f
,
0x0c
,
0x5f
,
0x15
,
0xe5
,
0xd8
,
0x67
,
0xf2
,
0x44
,
0xe5
,
0xf3
,
0x98
,
0x59
,
0x14
,
0x4e
,
0xa9
,
0x69
,
0xab
,
0x7c
,
0xca
,
0xa3
,
0x56
,
0x75
,
0x37
,
0xca
,
0xb3
,
0x21
,
0xa6
,
0xdd
,
0x58
,
0xd6
,
0x2c
,
0x6c
,
0x14
,
0x52
,
0xf7
,
0x3d
,
0x9e
,
0xfd
,
0xc0
,
0xfc
,
0x11
,
0xee
,
0x33
,
0x1e
,
0x53
,
0x50
,
0x51
,
0x49
,
0x37
,
0x92
,
0xae
,
0x29
,
0x3b
,
0xdd
,
0xa4
,
0xb2
,
0xe8
,
0x26
,
0x35
,
0x1d
,
0x66
,
0x7a
,
0xfa
,
0xaf
,
0x65
,
0x58
,
0x4f
,
0x48
,
0xfa
,
0xcf
,
0x28
,
0xcd
,
0x73
,
0xb3
,
0xfa
,
0x0e
,
0x6e
,
0x4a
,
0xff
,
0x06
,
0x37
,
0xe5
,
0x7f
,
0xc2
,
0x0d
,
0xb9
,
0x05
,
0x95
,
0x70
,
0x14
,
0xf4
,
0xe2
,
0xe8
,
0xb5
,
0x62
,
0x57
,
0xd7
,
0x10
,
0x8e
,
0x02
,
0x1a
,
0xbd
,
0x16
,
0x64
,
0x1b
,
0xea
,
0x03
,
0x8e
,
0xbe
,
0xd7
,
0x4b
,
0xc4
,
0xd4
,
0xa9
,
0xea
,
0xe6
,
0x6f
,
0xe6
,
0x13
,
0x18
,
0xa1
,
0x7d
,
0xae
,
0x80
,
0x07
,
0xfa
,
0x9b
,
0xd6
,
0x06
,
0x13
,
0xc3
,
0x0d
,
0x80
,
0x64
,
0xa9
,
0xbf
,
0xca
,
0x8b
,
0x5a
,
0x40
,
0x16
,
0xdc
,
0x6f
,
0xc1
,
0x49
,
0x1f
,
0xf1
,
0x73
,
0xee
,
0xa3
,
0x66
,
0xfb
,
0x72
,
0x0a
,
0xf6
,
0xa7
,
0x05
,
0xeb
,
0xb9
,
0x78
,
0xad
,
0x64
,
0xef
,
0xeb
,
0xc0
,
0xa4
,
0x05
,
0xd7
,
0x93
,
0x5b
,
0x1c
,
0x70
,
0x1f
,
0x4d
,
0xbb
,
0xd8
,
0xba
,
0x5d
,
0xd6
,
0x78
,
0xae
,
0x0a
,
0xf2
,
0x10
,
0x3e
,
0x12
,
0x18
,
0x73
,
0xe6
,
0xf3
,
0x73
,
0xf4
,
0x7a
,
0x82
,
0x9f
,
0x27
,
0xe2
,
0xb6
,
0x42
,
0xd7
,
0x26
,
0xee
,
0x03
,
0x7e
,
0x8e
,
0xee
,
0x1b
,
0x0b
,
0x6e
,
0x15
,
0x90
,
0x70
,
0x15
,
0xea
,
0xbb
,
0x00
,
0x99
,
0xf3
,
0x25
,
0x82
,
0x76
,
0x7f
,
0xae
,
0xa0
,
0x65
,
0x99
,
0xa3
,
0xd5
,
0x41
,
0x7a
,
0x04
,
0xf7
,
0x17
,
0xdb
,
0xfc
,
0x1c
,
0xf6
,
0x50
,
0xb2
,
0x85
,
0xde
,
0xdf
,
0xf8
,
0x07
,
0xb2
,
0x7c
,
0xa9
,
0x1f
,
0xc8
,
0x5d
,
0xa8
,
0x0d
,
0x18
,
0xf7
,
0x7b
,
0x46
,
0xe8
,
0x6d
,
0xfd
,
0x6e
,
0x41
,
0xb9
,
0xa8
,
0xf6
,
0x90
,
0xaf
,
0xc1
,
0x8e
,
0xf1
,
0x54
,
0xf3
,
0x37
,
0xa7
,
0x90
,
0x19
,
0xbd
,
0xa0
,
0x2a
,
0xa2
,
0xf0
,
0xba
,
0x56
,
0x0b
,
0xaf
,
0x6b
,
0x03
,
0xea
,
0x01
,
0x8b
,
0x5f
,
0xf6
,
0x3c
,
0xf4
,
0x51
,
0xa2
,
0xe7
,
0x94
,
0x9a
,
0x56
,
0xab
,
0x42
,
0x6b
,
0xca
,
0xd7
,
0x4d
,
0x5c
,
0x99
,
0xa9
,
0xa0
,
0x9c
,
0x9d
,
0x0a
,
0xb2
,
0x7a
,
0x5c
,
0xc9
,
0xeb
,
0x71
,
0x03
,
0x2a
,
0x31
,
0xf6
,
0xcf
,
0xfa
,
0x3e
,
0x7a
,
0xfa
,
0x39
,
0x56
,
0xe8
,
0xd8
,
0x26
,
0xf7
,
0x61
,
0xd2
,
0x08
,
0x49
,
0x7b
,
0x80
,
0x6e
,
0x8f
,
0x6b
,
0x63
,
0xaf
,
0xee
,
0x8e
,
0x47
,
0x70
,
0xbd
,
0x1b
,
0x47
,
0xc3
,
0x9c
,
0x14
,
0x66
,
0x74
,
0xcc
,
0xca
,
0xe9
,
0x58
,
0xe7
,
0x6d
,
0x09
,
0x40
,
0x43
,
0xb7
,
0xd5
,
0x74
,
0x46
,
0x86
,
0x40
,
0x76
,
0x50
,
0x6e
,
0x47
,
0xc1
,
0x30
,
0x0a
,
0x31
,
0x94
,
0xc9
,
0x7f
,
0x92
,
0x3c
,
0x99
,
0x33
,
0x62
,
0xcc
,
0x42
,
0x4d
,
0xc2
,
0xc6
,
0x83
,
0x39
,
0x11
,
0x53
,
0x70
,
0x77
,
0x89
,
0x04
,
0x3a
,
0xe3
,
0x21
,
0x0f
,
0xf0
,
0x90
,
0xf7
,
0x5f
,
0x6e
,
0x9f
,
0xb0
,
0x30
,
0x44
,
0xff
,
0xa2
,
0x8c
,
0x53
,
0xd0
,
0x34
,
0xe3
,
0x67
,
0xf9
,
0x08
,
0x63
,
0x1c
,
0xc8
,
0x98
,
0x87
,
0xc7
,
0xe9
,
0xdb
,
0x70
,
0x97
,
0xc8
,
0x29
,
0xdc
,
0xd8
,
0x41
,
0x9d
,
0x9d
,
0x0b
,
0xc9
,
0xfb
,
0x22
,
0x4d
,
0xd8
,
0x99
,
0x9f
,
0x70
,
0x06
,
0x7c
,
0xc9
,
0x94
,
0x3f
,
0x01
,
0x4c
,
0x9a
,
0x8d
,
0x2c
,
0xd6
,
0x8c
,
0xb3
,
0x04
,
0x4e
,
0xc3
,
0xc6
,
0xdb
,
0x73
,
0x58
,
0xcb
,
0x8f
,
0x35
,
0xe4
,
0xf3
,
0xa2
,
0xd8
,
0xc2
,
0xa1
,
0xaf
,
0xf1
,
0xc5
,
0x22
,
0xd0
,
0x71
,
0xaa
,
0x18
,
0xd6
,
0x67
,
0x74
,
0x87
,
0x3c
,
0xba
,
0x68
,
0x8b
,
0x69
,
0x8d
,
0x6e
,
0x3c
,
0x5e
,
0x10
,
0x3d
,
0xce
,
0xb9
,
0x0f
,
0xd5
,
0x71
,
0x3b
,
0x93
,
0x7b
,
0x45
,
0xd1
,
0xd3
,
0xdd
,
0xde
,
0xb8
,
0x48
,
0xf1
,
0xdc
,
0x25
,
0xd2
,
0x03
,
0xd8
,
0x41
,
0xb9
,
0x87
,
0x32
,
0xe6
,
0x7d
,
0x41
,
0x1e
,
0x14
,
0x5e
,
0xe2
,
0x04
,
0x90
,
0x6e
,
0xfa
,
0xf0
,
0x9d
,
0xb8
,
0xf4
,
0xc8
,
0x9d
,
0x37
,
0x2b
,
0x46
,
0x06
,
0xd5
,
0xc4
,
0xff
,
0xe1
,
0x49
,
0xbd
,
0x87
,
0x27
,
0x75
,
0x08
,
0xb5
,
0xcc
,
0x0c
,
0x4d
,
0x0a
,
0x1f
,
0xcb
,
0xec
,
0x90
,
0xfd
,
0x7f
,
0x37
,
0xc6
,
0xd6
,
0x97
,
0x3f
,
0x76
,
0x8e
,
0xb9
,
0x3c
,
0x19
,
0x1d
,
0xa9
,
0xd4
,
0x9b
,
0x09
,
0xf2
,
0x31
,
0x8f
,
0xcc
,
0xd7
,
0x66
,
0xca
,
0xd0
,
0xa6
,
0xde
,
0x69
,
0x53
,
0x97
,
0x31
,
0x3c
,
0x3a
,
0x2a
,
0x69
,
0xf3
,
0xe9
,
0xdf
,
0x01
,
0x00
,
0x00
,
0xff
,
0xff
,
0xd8
,
0x29
,
0x0d
,
0x3e
,
0x47
,
0x0f
,
0x00
,
0x00
,
}
...
...
internal/querycoord/cluster.go
浏览文件 @
ef3b71f2
...
...
@@ -35,7 +35,6 @@ import (
"github.com/milvus-io/milvus/internal/proto/internalpb"
"github.com/milvus-io/milvus/internal/proto/milvuspb"
"github.com/milvus-io/milvus/internal/proto/querypb"
"github.com/milvus-io/milvus/internal/storage"
"github.com/milvus-io/milvus/internal/util/sessionutil"
"github.com/milvus-io/milvus/internal/util/typeutil"
)
...
...
@@ -721,20 +720,7 @@ func estimateSegmentsSize(segments *querypb.LoadSegmentsRequest, kvClient kv.Dat
// get index size
if
loadInfo
.
EnableIndex
{
for
_
,
pathInfo
:=
range
loadInfo
.
IndexPathInfos
{
for
_
,
path
:=
range
pathInfo
.
IndexFilePaths
{
indexSize
,
err
:=
storage
.
EstimateMemorySize
(
kvClient
,
path
)
if
err
!=
nil
{
indexSize
,
err
=
storage
.
GetBinlogSize
(
kvClient
,
path
)
if
err
!=
nil
{
log
.
Warn
(
"estimate index size wrong"
,
zap
.
Int64
(
"segmentID"
,
loadInfo
.
GetSegmentID
()),
zap
.
String
(
"path"
,
path
),
zap
.
Error
(
err
))
return
0
,
err
}
}
segmentSize
+=
indexSize
}
segmentSize
+=
int64
(
pathInfo
.
GetSerializedSize
())
}
continue
}
...
...
internal/querycoord/cluster_test.go
浏览文件 @
ef3b71f2
...
...
@@ -700,17 +700,19 @@ func TestEstimateSegmentSize(t *testing.T) {
indexInfo
:=
&
indexpb
.
IndexFilePathInfo
{
IndexFilePaths
:
indexPath
,
SerializedSize
:
1024
,
}
loadInfo
.
IndexPathInfos
=
[]
*
indexpb
.
IndexFilePathInfo
{
indexInfo
}
loadInfo
.
EnableIndex
=
true
size
,
err
=
estimateSegmentsSize
(
loadReq
,
dataKV
)
assert
.
NoError
(
t
,
err
)
assert
.
NotEqual
(
t
,
int64
(
0
),
size
)
assert
.
Equal
(
t
,
int64
(
1024
),
size
)
indexInfo
.
IndexFilePaths
=
[]
string
{
"&*^*(^*(&*%^&*^(&"
}
indexInfo
.
SerializedSize
=
0
size
,
err
=
estimateSegmentsSize
(
loadReq
,
dataKV
)
assert
.
Error
(
t
,
err
)
assert
.
No
Error
(
t
,
err
)
assert
.
Equal
(
t
,
int64
(
0
),
size
)
cancel
()
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录