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

stream recover

This commit is contained in:
liuyao 2023-10-07 19:24:21 +08:00
parent c088ee7f91
commit 95ffe6fa23
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -178,7 +178,10 @@ SStreamFileState* streamFileStateInit(int64_t memSize, uint32_t keySize, uint32_
pFileState->maxTs = INT64_MIN; pFileState->maxTs = INT64_MIN;
pFileState->id = taosStrdup(taskId); pFileState->id = taosStrdup(taskId);
recoverSnapshot(pFileState, checkpointId); //todo(liuyao) optimize
if (type == STREAM_STATE_BUFF_HASH) {
recoverSnapshot(pFileState, checkpointId);
}
return pFileState; return pFileState;
_error: _error:
@ -644,7 +647,6 @@ int32_t deleteExpiredCheckPoint(SStreamFileState* pFileState, TSKEY mark) {
return code; return code;
} }
//todo(liuyao) session需要支持recover，需要修改下面代码，下面只是interval的。
int32_t recoverSnapshot(SStreamFileState* pFileState, int64_t ckId) { int32_t recoverSnapshot(SStreamFileState* pFileState, int64_t ckId) {
int32_t code = TSDB_CODE_SUCCESS; int32_t code = TSDB_CODE_SUCCESS;
if (pFileState->maxTs != INT64_MIN) { if (pFileState->maxTs != INT64_MIN) {