From eb1f09f47fd7e2d1d28711f70e1a53e22370709e Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 23 May 2024 17:25:22 +0800 Subject: [PATCH] refactor: do some internal refactor. --- source/libs/stream/src/streamExec.c | 5 ----- 1 file changed, 5 deletions(-) diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c index 8ac187a2bb..8da737783c 100644 --- a/source/libs/stream/src/streamExec.c +++ b/source/libs/stream/src/streamExec.c @@ -297,11 +297,6 @@ SScanhistoryDataInfo streamScanHistoryData(SStreamTask* pTask, int64_t st) { // dispatch the generated results /*int32_t code = */handleSanhistoryResultBlocks(pTask, pRes, size); - // downstream task input queue is full, try in 5sec - if (pTask->inputq.status == TASK_INPUT_STATUS__BLOCKED && (pTask->info.fillHistory == 1)) { - return buildScanhistoryExecRet(TASK_SCANHISTORY_REXEC, FILL_HISTORY_TASK_EXEC_INTERVAL); - } - if (finished) { return buildScanhistoryExecRet(TASK_SCANHISTORY_CONT, 0); }