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

fix(stream): ignore the check status when is ready.

This commit is contained in:
Haojun Liao 2023-10-24 11:38:14 +08:00
parent c99f434706
commit 7cce53f7e5
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -91,10 +91,13 @@ int32_t tqStartStreamTask(STQ* pTq) {
continue; continue;
} }
if (pTask->status.downstreamReady == 1 && HAS_RELATED_FILLHISTORY_TASK(pTask)) { if (pTask->status.downstreamReady == 1) {
tqDebug("s-task:%s downstream ready, no need to check downstream, check only related fill-history task", if (HAS_RELATED_FILLHISTORY_TASK(pTask)) {
pTask->id.idStr); tqDebug("s-task:%s downstream ready, no need to check downstream, check only related fill-history task",
streamLaunchFillHistoryTask(pTask); pTask->id.idStr);
streamLaunchFillHistoryTask(pTask);
}
streamMetaReleaseTask(pMeta, pTask); streamMetaReleaseTask(pMeta, pTask);
continue; continue;
} }