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

fix(stream): send kill checkpoint trans msg before close task.

This commit is contained in:
Haojun Liao 2024-08-09 00:47:42 +08:00
parent 8472f25a6e
commit e3a2733fee
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1140,12 +1140,16 @@ void streamMetaNotifyClose(SStreamMeta* pMeta) {
taosMsleep(100); taosMsleep(100);
} }
streamMetaRLock(pMeta);
SArray* pTaskList = NULL; SArray* pTaskList = NULL;
int32_t code = streamMetaSendMsgBeforeCloseTasks(pMeta, &pTaskList); int32_t code = streamMetaSendMsgBeforeCloseTasks(pMeta, &pTaskList);
if (code != TSDB_CODE_SUCCESS) { if (code != TSDB_CODE_SUCCESS) {
// return code; // return code;
} }
streamMetaRUnLock(pMeta);
if (pTaskList != NULL) { if (pTaskList != NULL) {
taosArrayDestroy(pTaskList); taosArrayDestroy(pTaskList);
} }