From ed22dd5f26a4479c41d27a7db3a79b1f266f33db Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Mon, 4 Sep 2023 14:09:39 +0800 Subject: [PATCH] fix(stream): fix deadlock caused during merging branch. --- source/dnode/vnode/src/tq/tqStreamTask.c | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/source/dnode/vnode/src/tq/tqStreamTask.c b/source/dnode/vnode/src/tq/tqStreamTask.c index f15bfd26a2..3c0321f300 100644 --- a/source/dnode/vnode/src/tq/tqStreamTask.c +++ b/source/dnode/vnode/src/tq/tqStreamTask.c @@ -386,16 +386,6 @@ int32_t doScanWalForAllTasks(SStreamMeta* pStreamMeta, bool* pScanIdle) { continue; } - taosThreadMutexLock(&pTask->lock); - pStatus = streamGetTaskStatusStr(pTask->status.taskStatus); - - if (pTask->status.taskStatus != TASK_STATUS__NORMAL) { - tqDebug("s-task:%s not ready for submit block from wal, status:%s", pTask->id.idStr, pStatus); - taosThreadMutexUnlock(&pTask->lock); - streamMetaReleaseTask(pStreamMeta, pTask); - continue; - } - if (pItem != NULL) { noDataInWal = false; code = streamTaskPutDataIntoInputQ(pTask, pItem);