From 6044c7511800f470ac27eb74d019cccec113570e Mon Sep 17 00:00:00 2001
From: Liu Jicong <liujicong@qq.com>
Date: Mon, 14 Mar 2022 20:51:13 +0800
Subject: [PATCH] fix worker init

---
 source/dnode/mgmt/impl/src/dndSnode.c | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/source/dnode/mgmt/impl/src/dndSnode.c b/source/dnode/mgmt/impl/src/dndSnode.c
index d192d9df01..b27a25680a 100644
--- a/source/dnode/mgmt/impl/src/dndSnode.c
+++ b/source/dnode/mgmt/impl/src/dndSnode.c
@@ -167,12 +167,15 @@ static int32_t dndStartSnodeWorker(SDnode *pDnode) {
   SSnodeMgmt *pMgmt = &pDnode->smgmt;
   pMgmt->uniqueWorkers = taosArrayInit(0, sizeof(void *));
   for (int32_t i = 0; i < 2; i++) {
-    SDnodeWorker uniqueWorker;
-    if (dndInitWorker(pDnode, &uniqueWorker, DND_WORKER_MULTI, "snode-unique", 1, 1, dndProcessSnodeSharedQueue) != 0) {
+    SDnodeWorker *pUniqueWorker = malloc(sizeof(SDnodeWorker));
+    if (pUniqueWorker == NULL) {
+      return -1;
+    }
+    if (dndInitWorker(pDnode, pUniqueWorker, DND_WORKER_MULTI, "snode-unique", 1, 1, dndProcessSnodeSharedQueue) != 0) {
       dError("failed to start snode unique worker since %s", terrstr());
       return -1;
     }
-    taosArrayPush(pMgmt->uniqueWorkers, &uniqueWorker);
+    taosArrayPush(pMgmt->uniqueWorkers, &pUniqueWorker);
   }
   if (dndInitWorker(pDnode, &pMgmt->sharedWorker, DND_WORKER_SINGLE, "snode-shared", 4, 4,
                     dndProcessSnodeSharedQueue)) {