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

adj operator res

This commit is contained in:
54liuyao 2024-07-22 13:05:39 +08:00
parent 6e70da62fb
commit fd6c1ecf37
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -241,8 +241,8 @@ static int32_t getSBf(SUpdateInfo* pInfo, TSKEY ts, SScalableBf** ppSBf) {
} }
int64_t index = (int64_t)((ts - pInfo->minTS) / pInfo->interval); int64_t index = (int64_t)((ts - pInfo->minTS) / pInfo->interval);
if (index < 0) { if (index < 0) {
code = TSDB_CODE_FAILED; (*ppSBf) = NULL;
QUERY_CHECK_CODE(code, lino, _end); goto _end;
} }
if (index >= pInfo->numSBFs) { if (index >= pInfo->numSBFs) {
uint64_t count = index + 1 - pInfo->numSBFs; uint64_t count = index + 1 - pInfo->numSBFs;

5
source/util/src/tscalablebf.c
View File

@ -221,8 +221,9 @@ int32_t tScalableBfDecode(SDecoder* pDecoder, SScalableBf** ppSBf) {
QUERY_CHECK_CODE(code, lino, _error); QUERY_CHECK_CODE(code, lino, _error);
} }
if (size == 0) { if (size == 0) {
code = TSDB_CODE_FAILED; (*ppSBf) = NULL;
QUERY_CHECK_CODE(code, lino, _error); tScalableBfDestroy(pSBf);
goto _error;
} }
pSBf->bfArray = taosArrayInit(size * 2, POINTER_BYTES); pSBf->bfArray = taosArrayInit(size * 2, POINTER_BYTES);
if (!pSBf->bfArray) { if (!pSBf->bfArray) {