Fix shards mismatch pod name (#4565)

* skip pod if name mismatch

Signed-off-by: yinghao.zou <yinghao.zou@zilliz.com>

* [skip ci] update changlog

Signed-off-by: yinghao.zou <yinghao.zou@zilliz.com>

* [skip ci] fix variable name typo

Signed-off-by: yinghao.zou <yinghao.zou@zilliz.com>
pull/4569/head
BossZou 2021-01-05 11:12:36 +08:00 committed by GitHub
parent 810f5e6f70
commit 9088b2c711
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 0 deletions

View File

@ -3,6 +3,7 @@
Please mark all change in change log and use the issue from GitHub
# Milvus 0.10.5 (TBD)
## Bug
- \#4296,#4554 Fix mishards add name-mismatched pod to read-only group
- \#4307 Specify partition to load for load_collection()
- \#4378 Multi-threads to call load_collection() and search() cause Milvus hang
- \#4484 Milvus only search default partition if search parameter 'partition_tags' contains '_default'

View File

@ -208,6 +208,10 @@ class EventHandler(threading.Thread):
pods_with_event = set()
for each_event in event['events']:
if not re.match(self.pod_patt, each_event['pod']):
# logger.warning(f"Do not match pod {each_event['pod']}")
# Pod name mismatch, do not add it
return
pods_with_event.add(each_event['pod'])
if each_event['ready']:
self.record_pending_add(each_event['pod'],