xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

refactor(stream): idle for 1s when exec for 5s.

This commit is contained in:
Haojun Liao 2025-02-11 21:47:39 +08:00
parent cc62216c14
commit 0600fcceeb
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/libs/stream/src/streamExec.c
View File

@ -778,6 +778,7 @@ static int32_t doStreamExecTask(SStreamTask* pTask) {
// merge multiple input data if possible in the input queue. // merge multiple input data if possible in the input queue.
stDebug("s-task:%s start to extract data block from inputQ", id); stDebug("s-task:%s start to extract data block from inputQ", id);
int64_t st = taosGetTimestampMs();
while (1) { while (1) {
int32_t blockSize = 0; int32_t blockSize = 0;
@ -807,7 +808,7 @@ static int32_t doStreamExecTask(SStreamTask* pTask) {
return 0; return 0;
} }
int64_t st = taosGetTimestampMs();
EExtractDataCode ret = streamTaskGetDataFromInputQ(pTask, &pInput, &numOfBlocks, &blockSize); EExtractDataCode ret = streamTaskGetDataFromInputQ(pTask, &pInput, &numOfBlocks, &blockSize);
if (ret == EXEC_AFTER_IDLE) { if (ret == EXEC_AFTER_IDLE) {