From bfd14076d7f54002ba757aa825d7dc46f79cabbb Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Mon, 6 Nov 2023 12:05:47 +0800
Subject: [PATCH] fix(stream): fix dead-lock.

---
 source/dnode/vnode/src/tq/tqStreamTask.c | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/source/dnode/vnode/src/tq/tqStreamTask.c b/source/dnode/vnode/src/tq/tqStreamTask.c
index f7607dabab..6e0e63b67d 100644
--- a/source/dnode/vnode/src/tq/tqStreamTask.c
+++ b/source/dnode/vnode/src/tq/tqStreamTask.c
@@ -165,12 +165,15 @@ int32_t tqRestartStreamTasks(STQ* pTq) {
   if (vnodeIsRoleLeader(pTq->pVnode) && !tsDisableStream) {
     tqInfo("vgId:%d restart all stream tasks after all tasks being updated", vgId);
     tqResetStreamTaskStatus(pTq);
+    streamMetaWUnLock(pMeta);
+
     tqStartStreamTasks(pTq);
   } else {
+    streamMetaWUnLock(pMeta);
+
     tqInfo("vgId:%d, follower node not start stream tasks", vgId);
   }
 
-  streamMetaWUnLock(pMeta);
   code = terrno;
   return code;
 }