xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Merge pull request #27798 from taosdata/hjxilinx-patch-2 

fix(stream): remove invalid sleep
This commit is contained in:
Haojun Liao 2024-09-11 10:23:13 +08:00 committed by GitHub
parent 3f0603128c 064a271582
commit c0876ead80
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 0 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/libs/stream/src/streamDispatch.c
View File

@ -1486,8 +1486,6 @@ int32_t streamProcessDispatchRsp(SStreamTask* pTask, SStreamDispatchRsp* pRsp, i
int32_t numOfFailed = 0; int32_t numOfFailed = 0;
bool triggerDispatchRsp = false; bool triggerDispatchRsp = false;
taosMsleep(500);
// we only set the dispatch msg info for current checkpoint trans // we only set the dispatch msg info for current checkpoint trans
streamMutexLock(&pTask->lock); streamMutexLock(&pTask->lock);
triggerDispatchRsp = (streamTaskGetStatus(pTask).state == TASK_STATUS__CK) && triggerDispatchRsp = (streamTaskGetStatus(pTask).state == TASK_STATUS__CK) &&