[Bug]: Data race at tests/integration/target TestTarget

[bigsheeper]

Is there an existing issue for this?

• I have searched the existing issues

Environment

- Milvus version:
- Deployment mode(standalone or cluster):
- MQ type(rocksmq, pulsar or kafka):    
- SDK version(e.g. pymilvus v2.0.0rc2):
- OS(Ubuntu or CentOS): 
- CPU/Memory: 
- GPU: 
- Others:

Current Behavior

https://productionresultssa0.blob.core.windows.net/actions-results/617d9b8a-a122-46f6-b297-e4f81eeebf85/workflow-job-run-a15168b4-2827-5d1a-d23e-1601e9ea4678/logs/job/job-logs.txt?rsct=text%2Fplain&se=2025-02-28T06%3A21%3A56Z&sig=VPNOe84D7OOGJDIbWLN5BfVMpBNbitgaHE%2BarumUpbI%3D&ske=2025-02-28T14%3A42%3A41Z&skoid=ca7593d4-ee42-46cd-af88-8b886a2f84eb&sks=b&skt=2025-02-28T02%3A42%3A41Z&sktid=398a6654-997b-47e9-b12b-9515b896b4de&skv=2025-01-05&sp=r&spr=https&sr=b&st=2025-02-28T06%3A11%3A51Z&sv=2025-01-05

Expected Behavior

No response

Steps To Reproduce

Milvus Log

No response

Anything else?

No response

[dosubot]

I found a similar closed issue titled "[Bug]: root_coord proxy_client_manager datarace in integration test" ^[1]. However, no solution was found in the comments of that issue.

For handling data races, Milvus typically uses synchronization mechanisms like sync.RWMutex to manage concurrent access to shared resources. For example, in the task_scheduler.go file, sync.RWMutex is used to protect access to shared maps, ensuring thread-safe operations ^[2][3]. Additionally, the github.com/sasha-s/go-deadlock library is used for detecting and handling data races ^[4].

In the specific case of the TestTarget, functions like SetSession and GetSession in internal/datanode/data_node.go use a mutex to prevent data races when accessing shared variables ^[5]. You might want to check if similar synchronization is needed in the code involved in the reported data race.

To continue talking to Dosu, mention @dosu.

---

^{Help Dosu learn! Give it feedback: Great Response | Irrelevant Answer | Incorrect Sources | Too Verbose | Hallucination | Bug Report | Other}