diff --git a/src/dnode/src/dnodeSystem.c b/src/dnode/src/dnodeSystem.c
index be3e03a72c5f1bf298de262f0168842f0fc1ab2b..59b1ffeb7d7db5bbff41c4c3d837bbc10f31bcc2 100644
--- a/src/dnode/src/dnodeSystem.c
+++ b/src/dnode/src/dnodeSystem.c
@@ -47,7 +47,6 @@ static pthread_mutex_t tsDnodeMutex;
 static SDnodeRunStatus tsDnodeRunStatus = TSDB_DNODE_RUN_STATUS_STOPPED;
 
 static int32_t dnodeInitRpcQHandle();
-static int32_t dnodeInitQueryQHandle();
 static int32_t dnodeInitTmrCtl();
 
 
@@ -57,8 +56,6 @@ int32_t (*dnodeInitPeers)(int32_t numOfThreads) = NULL;
 
 void     *tsDnodeTmr;
 void     **tsRpcQhandle;
-void     *tsDnodeMgmtQhandle;
-void     *tsQueryQhandle;
 int32_t  tsVnodePeers   = TSDB_VNODES_SUPPORT - 1;
 int32_t  tsMaxQueues;
 uint32_t tsRebootTime;
@@ -193,11 +190,6 @@ int32_t dnodeInitSystem() {
     return -1;
   }
 
-  if (dnodeInitQueryQHandle() < 0) {
-    dError("failed to init query qhandle, exit");
-    return -1;
-  }
-
   if (dnodeInitMgmt() < 0) {
     dError("failed to init vnode storage");
     return -1;
@@ -251,20 +243,6 @@ int32_t dnodeInitStorageImp() {
   return 0;
 }
 
-static int32_t dnodeInitQueryQHandle() {
-  int32_t numOfThreads = tsRatioOfQueryThreads * tsNumOfCores * tsNumOfThreadsPerCore;
-  if (numOfThreads < 1) {
-    numOfThreads = 1;
-  }
-
-  int32_t maxQueueSize = tsNumOfVnodesPerCore * tsNumOfCores * tsSessionsPerVnode;
-  dTrace("query task queue initialized, max slot:%d, task threads:%d", maxQueueSize, numOfThreads);
-
-  tsQueryQhandle = taosInitSchedulerWithInfo(maxQueueSize, numOfThreads, "query", tsDnodeTmr);
-
-  return 0;
-}
-
 static int32_t dnodeInitTmrCtl() {
   tsDnodeTmr = taosTmrInit(TSDB_MAX_VNODES * (tsVnodePeers + 10) + tsSessionsPerVnode + 1000, 200, 60000,
                              "DND-vnode");
@@ -288,8 +266,6 @@ static int32_t dnodeInitRpcQHandle() {
     tsRpcQhandle[i] = taosInitScheduler(tsSessionsPerVnode, 1, "dnode");
   }
 
-  tsDnodeMgmtQhandle = taosInitScheduler(tsSessionsPerVnode, 1, "mgmt");
-
   return 0;
 }
 
diff --git a/src/inc/dnode.h b/src/inc/dnode.h
index ff893acd38a7ea8c80309d43c2499376155c2dda..88fe6a2aee8e901d4fe9e286350d7e90a3b5d129 100644
--- a/src/inc/dnode.h
+++ b/src/inc/dnode.h
@@ -46,7 +46,6 @@ extern int32_t (*dnodeCheckSystem)();
 
 
 // dnodeSystem
-extern void *tsDnodeMgmtQhandle;
 void dnodeCheckDataDirOpenned(const char* dir);
 
 // dnodeModule