From 226b6596d61f72a0cffb6906b2aaf05ee04bd9be Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Fri, 20 Oct 2023 15:54:30 +0800 Subject: [PATCH] fix(stream): fix bugs caused by refactor. --- source/dnode/vnode/src/tq/tqStreamTask.c | 2 +- source/libs/stream/src/streamTaskSm.c | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/source/dnode/vnode/src/tq/tqStreamTask.c b/source/dnode/vnode/src/tq/tqStreamTask.c index 4bc386fb9a..cb313b7eed 100644 --- a/source/dnode/vnode/src/tq/tqStreamTask.c +++ b/source/dnode/vnode/src/tq/tqStreamTask.c @@ -91,7 +91,7 @@ int32_t tqStartStreamTask(STQ* pTq) { continue; } - if (pTask->status.downstreamReady == 1) { + if (pTask->status.downstreamReady == 1 && HAS_RELATED_FILLHISTORY_TASK(pTask)) { tqDebug("s-task:%s downstream ready, no need to check downstream, check only related fill-history task", pTask->id.idStr); streamLaunchFillHistoryTask(pTask); diff --git a/source/libs/stream/src/streamTaskSm.c b/source/libs/stream/src/streamTaskSm.c index 7abdd155b9..3e148c0a35 100644 --- a/source/libs/stream/src/streamTaskSm.c +++ b/source/libs/stream/src/streamTaskSm.c @@ -33,7 +33,7 @@ SStreamTaskState StreamTaskStatusList[9] = { }; SStreamEventInfo StreamTaskEventList[12] = { - {}, // dummy event, place holder + {.event = 0, .name = ""}, // dummy event, place holder {.event = TASK_EVENT_INIT, .name = "initialize"}, {.event = TASK_EVENT_INIT_SCANHIST, .name = "scan-history-init"}, {.event = TASK_EVENT_INIT_STREAM_SCANHIST, .name = "stream-scan-history-init"},