diff --git a/source/dnode/mnode/impl/inc/mndStream.h b/source/dnode/mnode/impl/inc/mndStream.h
index 58a4c92d3e..e72b2ed536 100644
--- a/source/dnode/mnode/impl/inc/mndStream.h
+++ b/source/dnode/mnode/impl/inc/mndStream.h
@@ -50,6 +50,7 @@ typedef struct SStreamExecInfo {
   SHashObj        *pTaskMap;
   SArray          *pTaskList;
   TdThreadMutex    lock;
+  SHashObj        *pTransferStateStreams;
 } SStreamExecInfo;
 
 #define MND_STREAM_CREATE_NAME      "stream-create"
diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c
index 55951c19bb..aa91bd7691 100644
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@@ -151,6 +151,8 @@ int32_t mndInitStream(SMnode *pMnode) {
   execInfo.pTaskMap = taosHashInit(64, fn, true, HASH_NO_LOCK);
   execInfo.transMgmt.pDBTrans = taosHashInit(32, fn, true, HASH_NO_LOCK);
   execInfo.transMgmt.pWaitingList = taosHashInit(32, fn, true, HASH_NO_LOCK);
+  execInfo.pTransferStateStreams = taosHashInit(32, fn, true, HASH_NO_LOCK);
+
   taosHashSetFreeFp(execInfo.transMgmt.pWaitingList, freeCheckpointCandEntry);
 
   if (sdbSetTable(pMnode->pSdb, table) != 0) {