mirror of https://github.com/milvus-io/milvus.git
[skip ci] Fix mishards error shen k8s find node fail (#4474)
Signed-off-by: yinghao.zou <yinghao.zou@zilliz.com>pull/4505/head
parent
805212a0dc
commit
e5d218f405
|
@ -14,6 +14,7 @@ import enum
|
|||
from functools import partial
|
||||
from collections import defaultdict
|
||||
from kubernetes import client, config as kconfig, watch
|
||||
from mishards.exceptions import ConnectionConnectError
|
||||
from mishards.topology import StatusType
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
@ -325,7 +326,7 @@ class KubernetesProvider(object):
|
|||
status, pool = group.create(name=name, uri=uri)
|
||||
except ConnectionConnectError as exc:
|
||||
ok = False
|
||||
logger.error('Connection error to: {}'.format(addr))
|
||||
logger.error('Connection error to: POD {} with IP {}'.format(name, ip))
|
||||
|
||||
# if ok and status == StatusType.OK:
|
||||
# logger.info('KubernetesProvider Add Group \"{}\" Of 1 Address: {}'.format(name, uri))
|
||||
|
|
|
@ -134,7 +134,8 @@ class ServiceHandler(milvus_pb2_grpc.MilvusServiceServicer):
|
|||
futures = []
|
||||
for addr, files_tuple in routing.items():
|
||||
search_file_ids, ud_file_ids = files_tuple
|
||||
logger.info(f"<{addr}> needed update segment ids {ud_file_ids}")
|
||||
if ud_file_ids:
|
||||
logger.debug(f"<{addr}> needed update segment ids {ud_file_ids}")
|
||||
conn = self.router.query_conn(addr, metadata=metadata)
|
||||
start = time.time()
|
||||
ud_file_ids and conn.reload_segments(collection_id, ud_file_ids)
|
||||
|
|
Loading…
Reference in New Issue