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

enh: rsma tasks share one checkpoint and fix memory leak

This commit is contained in:
kailixu 2023-11-08 08:35:52 +08:00
parent 6b738884a4
commit f2d24306b1
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/dnode/vnode/src/sma/smaRollup.c
View File

@ -1221,6 +1221,10 @@ _checkpoint:
smaInfo("vgId:%d, rsma commit, succeed to commit checkpoint/task:%" PRIi64 "/%p, table:%" PRIi64 ", level:%d", smaInfo("vgId:%d, rsma commit, succeed to commit checkpoint/task:%" PRIi64 "/%p, table:%" PRIi64 ", level:%d",
TD_VID(pVnode), pTask->checkpointingId, pTask, pRSmaInfo->suid, i + 1); TD_VID(pVnode), pTask->checkpointingId, pTask, pRSmaInfo->suid, i + 1);
// the stream states share one checkpoint
taosHashCancelIterate(pInfoHash, infoHash);
goto _exit;
} }
} }
} }

2
source/libs/stream/src/tstreamFileState.c
View File

@ -201,7 +201,7 @@ SStreamFileState* streamFileStateInit(int64_t memSize, uint32_t keySize, uint32_
streamFileStateDecode(&pFileState->flushMark, valBuf, len); streamFileStateDecode(&pFileState->flushMark, valBuf, len);
qDebug("===stream===flushMark read:%" PRId64, pFileState->flushMark); qDebug("===stream===flushMark read:%" PRId64, pFileState->flushMark);
} }
taosMemoryFreeClear(valBuf);
return pFileState; return pFileState;
_error: _error: