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

check stopping node during start qc (#27859) 

Signed-off-by: Wei Liu <wei.liu@zilliz.com>
pull/27721/head
wei liu 2023-10-24 12:20:11 +08:00 committed by GitHub
parent 906b348e00
commit 178db7b0f0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/querycoordv2/server.go
View File

@ -408,6 +408,10 @@ func (s *Server) startQueryCoord() error {
for _, node := range sessions {
s.nodeMgr.Add(session.NewNodeInfo(node.ServerID, node.Address))
s.taskScheduler.AddExecutor(node.ServerID)
if node.Stopping {
s.nodeMgr.Stopping(node.ServerID)
}
}
s.checkReplicas()
for _, node := range sessions {

6
internal/querycoordv2/server_test.go
View File

@ -167,6 +167,10 @@ func (suite *ServerSuite) TestRecover() {
err := suite.server.Stop()
suite.NoError(err)
// stopping querynode
downNode := suite.nodes[0]
downNode.Stopping()
suite.server, err = suite.newQueryCoord()
suite.NoError(err)
suite.hackServer()
@ -176,6 +180,8 @@ func (suite *ServerSuite) TestRecover() {
for _, collection := range suite.collections {
suite.True(suite.server.meta.Exist(collection))
}
suite.True(suite.server.nodeMgr.IsStoppingNode(suite.nodes[0].ID))
}
func (suite *ServerSuite) TestNodeUp() {