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

fix(stream): try starting task even the inputQ is full.

This commit is contained in:
Haojun Liao 2025-01-27 00:50:36 +08:00
parent f56aeaf1bd
commit ed03b3a22c
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/dnode/vnode/src/tq/tqStreamTask.c
View File

@ -317,9 +317,10 @@ bool taskReadyForDataFromWal(SStreamTask* pTask) {
return false; return false;
} }
// check if input queue is full or not // check whether input queue is full or not
if (streamQueueIsFull(pTask->inputq.queue)) { if (streamQueueIsFull(pTask->inputq.queue)) {
tqTrace("s-task:%s input queue is full, do nothing", pTask->id.idStr); tqTrace("s-task:%s input queue is full, launch task without scanning wal", pTask->id.idStr);
streamTrySchedExec(pTask);
return false; return false;
} }