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

support reopen stream state

This commit is contained in:
yihaoDeng 2023-08-09 07:36:00 +00:00
parent bbcfa9ab03
commit 92b247aae8
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/libs/stream/src/streamBackendRocksdb.c
View File

@ -245,8 +245,6 @@ int32_t backendManagerGetDelta(SBackendManager* bm, int64_t chkpId, SArray* list
bm->curChkpId = chkpId; bm->curChkpId = chkpId;
bm->init = 1; bm->init = 1;
// SArray* add = taosArrayInit(64, sizeof(void*));
void* pIter = taosHashIterate(pTable, NULL); void* pIter = taosHashIterate(pTable, NULL);
while (pIter) { while (pIter) {
size_t len; size_t len;
@ -258,9 +256,6 @@ int32_t backendManagerGetDelta(SBackendManager* bm, int64_t chkpId, SArray* list
} }
} else { } else {
// SArray* add = taosArrayInit(64, sizeof(void*));
// SArray* del = taosArrayInit(64, sizeof(void*));
int32_t code = compareHashTable(bm->pSSTable, pTable, bm->pAdd, bm->pDel); int32_t code = compareHashTable(bm->pSSTable, pTable, bm->pAdd, bm->pDel);
bm->curChkpId = chkpId; bm->curChkpId = chkpId;