fix(stream): fix a typo

59d5858b · Haojun Liao · 9a76ae72 · 59d5858b
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/libs/stream/src/streamExec.c source/libs/stream/src/streamExec.c +1 -1

未找到文件。
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -192,7 +192,7 @@ int32_t streamScanExec(SStreamTask* pTask, int32_t batchSize) {
      }

      if (pTask->inputStatus == TASK_INPUT_STATUS__BLOCKED) {
-        qDebug("s-task:%s inputQ is blocked, wait for 5sec and retry", pTask->id.idStr);
+        qDebug("s-task:%s inputQ is blocked, wait for 10sec and retry", pTask->id.idStr);
        taosMsleep(10000);
        continue;
      }