From 4267dc2efc064c6b68288c483f1bcdf953ff5fa3 Mon Sep 17 00:00:00 2001 From: "cai.zhang" Date: Wed, 6 Apr 2022 14:33:30 +0800 Subject: [PATCH] Handle error and oragnize log (#16367) Signed-off-by: cai.zhang --- internal/indexcoord/index_coord.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/internal/indexcoord/index_coord.go b/internal/indexcoord/index_coord.go index 74ad8b1916..262e207d32 100644 --- a/internal/indexcoord/index_coord.go +++ b/internal/indexcoord/index_coord.go @@ -823,8 +823,12 @@ func (i *IndexCoord) watchMetaLoop() { indexMeta := &indexpb.IndexMeta{} err := proto.Unmarshal(event.Kv.Value, indexMeta) indexBuildID := indexMeta.IndexBuildID - log.Debug("IndexCoord watchMetaLoop", zap.Any("event.Key", event.Kv.Key), - zap.Any("event.V", indexMeta), zap.Int64("IndexBuildID", indexBuildID), zap.Error(err)) + log.Debug("IndexCoord watchMetaLoop", zap.Int64("IndexBuildID", indexBuildID)) + if err != nil { + log.Warn("IndexCoord unmarshal indexMeta failed", zap.Int64("IndexBuildID", indexBuildID), + zap.Error(err)) + continue + } switch event.Type { case mvccpb.PUT: reload := i.metaTable.LoadMetaFromETCD(indexBuildID, eventRevision)