From 306f6ebc931317805323ff2d13f3586d6698557b Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 20 Feb 2025 23:54:06 +0800 Subject: [PATCH] fix(stream): clear start task info if no tasks exist. --- source/libs/stream/src/streamStartTask.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/source/libs/stream/src/streamStartTask.c b/source/libs/stream/src/streamStartTask.c index d9ca506849..60c1694dda 100644 --- a/source/libs/stream/src/streamStartTask.c +++ b/source/libs/stream/src/streamStartTask.c @@ -45,6 +45,10 @@ int32_t streamMetaStartAllTasks(SStreamMeta* pMeta) { if (numOfTasks == 0) { stInfo("vgId:%d no tasks exist, quit from consensus checkpointId", pMeta->vgId); + + streamMetaWLock(pMeta); + streamMetaResetStartInfo(&pMeta->startInfo, vgId); + streamMetaWUnLock(pMeta); return TSDB_CODE_SUCCESS; }