fix: [2.4] Prevent use captured iteration variable partitionID (milvu…

…s-io#33907) Cherry-pick from master pr: milvus-io#33906 See also milvus-io#33902 Signed-off-by: Congqi Xia <[email protected]>
shaoting-huang · Jun 17, 2024 · e807183 · e807183
1 parent 5fc1370
commit e807183
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/internal/querynodev2/delegator/delegator_data.go b/internal/querynodev2/delegator/delegator_data.go
@@ -303,8 +303,9 @@ func (sd *shardDelegator) applyBFInParallel(deleteDatas []*DeleteData, pool *con
 			retIdx += 1
 			tmpRetIdx := retIdx
 			deleteDataId := didx
+			partitionID := data.PartitionID
 			future := pool.Submit(func() (any, error) {
-				ret := sd.pkOracle.BatchGet(pks[startIdx:endIdx], pkoracle.WithPartitionID(data.PartitionID))
+				ret := sd.pkOracle.BatchGet(pks[startIdx:endIdx], pkoracle.WithPartitionID(partitionID))
 				retMap.Insert(tmpRetIdx, &BatchApplyRet{
 					DeleteDataIdx: deleteDataId,
 					StartIdx:      startIdx,