milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Check cluster error (#10116) 

Signed-off-by: godchen <qingxiang.chen@zilliz.com>
pull/10344/head
godchen 2021-10-21 10:57:03 +08:00 committed by GitHub
parent 132f57f5b7
commit c2fa2e940d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
internal/datacoord/cluster_test.go
View File

@ -392,7 +392,8 @@ func TestConsistentHashPolicy(t *testing.T) {
}
hash.Remove("1")
cluster.UnRegister(nodeInfo1)
err = cluster.UnRegister(nodeInfo1)
assert.Nil(t, err)
for _, c := range channels {
idstr, err := hash.Get(c)
assert.Nil(t, err)
@ -403,7 +404,8 @@ func TestConsistentHashPolicy(t *testing.T) {
}
hash.Remove("2")
cluster.UnRegister(nodeInfo2)
err = cluster.UnRegister(nodeInfo2)
assert.Nil(t, err)
for _, c := range channels {
idstr, err := hash.Get(c)
assert.Nil(t, err)
@ -414,7 +416,8 @@ func TestConsistentHashPolicy(t *testing.T) {
}
hash.Remove("3")
cluster.UnRegister(nodeInfo3)
err = cluster.UnRegister(nodeInfo3)
assert.Nil(t, err)
bufferChannels := channelManager.GetBuffer()
assert.EqualValues(t, 3, len(bufferChannels.Channels))
}