commit
e37811ee28
|
@ -470,6 +470,7 @@ static int32_t checkResult(SStreamFillSupporter* pFillSup, TSKEY ts, uint64_t gr
|
||||||
SWinKey key = {.groupId = groupId, .ts = ts};
|
SWinKey key = {.groupId = groupId, .ts = ts};
|
||||||
if (tSimpleHashGet(pFillSup->pResMap, &key, sizeof(SWinKey)) != NULL) {
|
if (tSimpleHashGet(pFillSup->pResMap, &key, sizeof(SWinKey)) != NULL) {
|
||||||
(*pRes) = false;
|
(*pRes) = false;
|
||||||
|
goto _end;
|
||||||
}
|
}
|
||||||
code = tSimpleHashPut(pFillSup->pResMap, &key, sizeof(SWinKey), NULL, 0);
|
code = tSimpleHashPut(pFillSup->pResMap, &key, sizeof(SWinKey), NULL, 0);
|
||||||
QUERY_CHECK_CODE(code, lino, _end);
|
QUERY_CHECK_CODE(code, lino, _end);
|
||||||
|
|
Loading…
Reference in New Issue