Merge pull request #21976 from taosdata/fix/TS-3611
fix:race condition for pTq->pStore->pHash
This commit is contained in:
commit
50c5dbffe2
|
@ -104,7 +104,7 @@ STqOffsetStore* tqOffsetOpen(STQ* pTq) {
|
|||
pStore->needCommit = 0;
|
||||
pTq->pOffsetStore = pStore;
|
||||
|
||||
pStore->pHash = taosHashInit(64, MurmurHash3_32, true, HASH_NO_LOCK);
|
||||
pStore->pHash = taosHashInit(64, MurmurHash3_32, true, HASH_ENTRY_LOCK);
|
||||
if (pStore->pHash == NULL) {
|
||||
taosMemoryFree(pStore);
|
||||
return NULL;
|
||||
|
|
Loading…
Reference in New Issue