From 4b8cd3bccdc175facdb665a796e220993b2a190a Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Mon, 9 Oct 2023 10:07:19 +0800
Subject: [PATCH] fix(stream): not idle for sink task when no tokens are
 available.

---
 source/libs/stream/src/streamQueue.c | 1 -
 1 file changed, 1 deletion(-)

diff --git a/source/libs/stream/src/streamQueue.c b/source/libs/stream/src/streamQueue.c
index 776b69848c..ae285046ef 100644
--- a/source/libs/stream/src/streamQueue.c
+++ b/source/libs/stream/src/streamQueue.c
@@ -169,7 +169,6 @@ int32_t streamTaskGetDataFromInputQ(SStreamTask* pTask, SStreamQueueItem** pInpu
   // no available token in bucket for sink task, let's wait for a little bit
   if (taskLevel == TASK_LEVEL__SINK && (!streamTaskExtractAvailableToken(pTask->outputInfo.pTokenBucket, pTask->id.idStr))) {
     stDebug("s-task:%s no available token in bucket for sink data, wait for 50ms", id);
-    taosMsleep(10);
     return TSDB_CODE_SUCCESS;
   }