enhance: Fix lb policy retry log after targetNode type changed (milvu…

…s-io#37646) Related to previous pr: milvus-io#37371 Signed-off-by: Congqi Xia <[email protected]> Signed-off-by: Wei Liu <[email protected]>
weiliu1031 · Nov 17, 2024 · e279861 · e279861
1 parent 564d381
commit e279861
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/internal/proxy/lb_policy.go b/internal/proxy/lb_policy.go
@@ -199,7 +199,7 @@ func (lb *LBPolicyImpl) ExecuteWithRetry(ctx context.Context, workload ChannelWo
 				zap.Error(err))
 			excludeNodes.Insert(targetNode.nodeID)
 
-			lastErr = errors.Wrapf(err, "failed to get delegator %d for channel %s", targetNode, workload.channel)
+			lastErr = errors.Wrapf(err, "failed to get delegator %d for channel %s", targetNode.nodeID, workload.channel)
 			return lastErr
 		}
 		defer lb.clientMgr.ReleaseClientRef(targetNode.nodeID)
@@ -212,7 +212,7 @@ func (lb *LBPolicyImpl) ExecuteWithRetry(ctx context.Context, workload ChannelWo
 				zap.Int64("nodeID", targetNode.nodeID),
 				zap.Error(err))
 			excludeNodes.Insert(targetNode.nodeID)
-			lastErr = errors.Wrapf(err, "failed to search/query delegator %d for channel %s", targetNode, workload.channel)
+			lastErr = errors.Wrapf(err, "failed to search/query delegator %d for channel %s", targetNode.nodeID, workload.channel)
 			return lastErr
 		}