From abf1f58abe0d82d65a4e2d8f5b6d311b59b705b4 Mon Sep 17 00:00:00 2001 From: xige-16 Date: Tue, 4 Jan 2022 20:45:24 +0800 Subject: [PATCH] Add log for watchDeltaChannelTask's nodeID (#14702) Signed-off-by: xige-16 --- internal/querynode/impl.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/querynode/impl.go b/internal/querynode/impl.go index 70300720fc..93cd20a7d3 100644 --- a/internal/querynode/impl.go +++ b/internal/querynode/impl.go @@ -267,7 +267,7 @@ func (node *QueryNode) WatchDeltaChannels(ctx context.Context, in *queryPb.Watch log.Error(err.Error()) return status, nil } - log.Debug("watchDeltaChannelsTask Enqueue done", zap.Any("collectionID", in.CollectionID)) + log.Debug("watchDeltaChannelsTask Enqueue done", zap.Int64("collectionID", in.CollectionID), zap.Int64("nodeID", Params.QueryNodeCfg.QueryNodeID)) waitFunc := func() (*commonpb.Status, error) { err = dct.WaitToFinish() @@ -279,7 +279,7 @@ func (node *QueryNode) WatchDeltaChannels(ctx context.Context, in *queryPb.Watch log.Error(err.Error()) return status, nil } - log.Debug("watchDeltaChannelsTask WaitToFinish done", zap.Any("collectionID", in.CollectionID)) + log.Debug("watchDeltaChannelsTask WaitToFinish done", zap.Int64("collectionID", in.CollectionID), zap.Int64("nodeID", Params.QueryNodeCfg.QueryNodeID)) return &commonpb.Status{ ErrorCode: commonpb.ErrorCode_Success, }, nil