fix(stream): remove delay rsp for dispatch

2024-09-11 10:10:17 +08:00 · 2024-09-11 10:10:17 +08:00 · fdd2bbf5fc
parent 37355b8ae1
commit fdd2bbf5fc
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) &&