From 8c0a74e7b2890b010f4525954f579d788786c912 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Fri, 24 May 2024 09:19:09 +0800 Subject: [PATCH] fix(stream):adjust the idle time. --- source/libs/stream/src/streamExec.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c index 8da737783c..934ff898a9 100644 --- a/source/libs/stream/src/streamExec.c +++ b/source/libs/stream/src/streamExec.c @@ -270,8 +270,8 @@ SScanhistoryDataInfo streamScanHistoryData(SStreamTask* pTask, int64_t st) { // output queue is full, idle for 5 sec. if (streamQueueIsFull(pTask->outputq.queue)) { - stWarn("s-task:%s outputQ is full, idle for 5sec and retry", id); - return buildScanhistoryExecRet(TASK_SCANHISTORY_REXEC, FILL_HISTORY_TASK_EXEC_INTERVAL); + stWarn("s-task:%s outputQ is full, idle for 1sec and retry", id); + return buildScanhistoryExecRet(TASK_SCANHISTORY_REXEC, STREAM_SCAN_HISTORY_TIMESLICE); } if (pTask->inputq.status == TASK_INPUT_STATUS__BLOCKED) {