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

Merge pull request #26295 from taosdata/fix/TD-30720 

fix(streamMeta): commit tdb after load tasks
This commit is contained in:
Hongze Cheng 2024-06-27 14:04:02 +08:00 committed by GitHub
parent 10237869d9 3014c66965
commit 5e235b50fa
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/stream/src/streamMeta.c
View File

@ -958,6 +958,8 @@ void streamMetaLoadAllTasks(SStreamMeta* pMeta) {
pMeta->numOfStreamTasks, pMeta->numOfPausedTasks); pMeta->numOfStreamTasks, pMeta->numOfPausedTasks);
taosArrayDestroy(pRecycleList); taosArrayDestroy(pRecycleList);
(void)streamMetaCommit(pMeta);
} }
static bool waitForEnoughDuration(SMetaHbInfo* pInfo) { static bool waitForEnoughDuration(SMetaHbInfo* pInfo) {
@ -1743,4 +1745,4 @@ void streamMetaClearUpdateTaskList(SStreamMeta* pMeta) {
void streamMetaInitUpdateTaskList(SStreamMeta* pMeta, int32_t transId) { void streamMetaInitUpdateTaskList(SStreamMeta* pMeta, int32_t transId) {
taosHashClear(pMeta->updateInfo.pTasks); taosHashClear(pMeta->updateInfo.pTasks);
pMeta->updateInfo.transId = transId; pMeta->updateInfo.transId = transId;
} }