Merge pull request #17317 from taosdata/feature/stream
refactor(stream): change state table name
This commit is contained in:
commit
92bc2561bf
|
@ -73,7 +73,7 @@ SStreamState* streamStateOpen(char* path, SStreamTask* pTask, bool specPath) {
|
|||
}
|
||||
|
||||
// todo refactor
|
||||
if (tdbTbOpen("func.state.db", sizeof(SWinKey), -1, winKeyCmpr, pState->db, &pState->pFillStateDb) < 0) {
|
||||
if (tdbTbOpen("fill.state.db", sizeof(SWinKey), -1, winKeyCmpr, pState->db, &pState->pFillStateDb) < 0) {
|
||||
goto _err;
|
||||
}
|
||||
|
||||
|
|
|
@ -279,7 +279,7 @@ static int32_t walFetchBodyNew(SWalReader *pRead) {
|
|||
terrno = TSDB_CODE_WAL_OUT_OF_MEMORY;
|
||||
return -1;
|
||||
}
|
||||
pRead->pHead = ptr;
|
||||
pRead->pHead = (SWalCkHead *)ptr;
|
||||
pReadHead = &pRead->pHead->head;
|
||||
pRead->capacity = pReadHead->bodyLen;
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue