test(stream): init lock.

This commit is contained in:
Haojun Liao 2024-02-22 09:52:47 +08:00
parent 637e604368
commit 045a30035f
1 changed files with 1 additions and 0 deletions

View File

@ -216,6 +216,7 @@ TEST_F(StreamTest, kill_checkpoint_trans) {
pTask->id.streamId = defStreamId;
pTask->id.taskId = 1;
pTask->exec.qmsg = (char*)taosMemoryMalloc(1);
taosThreadMutexInit(&pTask->lock, NULL);
taosArrayPush(pLevel, &pTask);