fix: SyncSegments rpc always failed (#38578)

miss the patch due to code branching previous pr: #38032 Signed-off-by: Congqi Xia <[email protected]> Co-authored-by: Wei Liu <[email protected]>
milvus-io · Dec 19, 2024 · 3d360c0 · 3d360c0
1 parent b537a72
commit 3d360c0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/internal/datacoord/session/datanode_manager.go b/internal/datacoord/session/datanode_manager.go
@@ -229,8 +229,8 @@ func (c *DataNodeManagerImpl) SyncSegments(ctx context.Context, nodeID int64, re
 		zap.Int64("nodeID", nodeID),
 		zap.Int64("planID", req.GetPlanID()),
 	)
-	ctx, cancel := context.WithTimeout(context.Background(), paramtable.Get().DataCoordCfg.CompactionRPCTimeout.GetAsDuration(time.Second))
-	cli, err := c.getClient(ctx, nodeID)
+	childCtx, cancel := context.WithTimeout(context.Background(), paramtable.Get().DataCoordCfg.CompactionRPCTimeout.GetAsDuration(time.Second))
+	cli, err := c.getClient(childCtx, nodeID)
 	cancel()
 	if err != nil {
 		log.Warn("failed to get client", zap.Error(err))