From 13e14d0f55b52b5ccdacd94d1d072c8c5ab356ae Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 17 Apr 2024 10:48:22 +0800 Subject: [PATCH] fix(stream): add return. --- source/libs/stream/src/streamExec.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c index d55382be83..93ede2707b 100644 --- a/source/libs/stream/src/streamExec.c +++ b/source/libs/stream/src/streamExec.c @@ -591,6 +591,7 @@ int32_t doStreamExecTask(SStreamTask* pTask) { if (ret == EXEC_AFTER_IDLE) { ASSERT(pInput == NULL && numOfBlocks == 0); setTaskSchedInfo(pTask, MIN_INVOKE_INTERVAL); + return 0; } else { if (pInput == NULL) { ASSERT(numOfBlocks == 0);