Update streamDispatch.c

2024-09-11 10:21:38 +08:00 · 2024-09-11 10:21:38 +08:00 · 064a271582
parent 3f0603128c
commit 064a271582
1 changed files with 0 additions and 2 deletions
--- a/source/libs/stream/src/streamDispatch.c
+++ b/source/libs/stream/src/streamDispatch.c
@ -1486,8 +1486,6 @@ int32_t streamProcessDispatchRsp(SStreamTask* pTask, SStreamDispatchRsp* pRsp, i
  int32_t           numOfFailed = 0;
  bool              triggerDispatchRsp = false;

-  taosMsleep(500);
-
  // we only set the dispatch msg info for current checkpoint trans
  streamMutexLock(&pTask->lock);
  triggerDispatchRsp = (streamTaskGetStatus(pTask).state == TASK_STATUS__CK) &&