diff --git a/include/common/tmsg.h b/include/common/tmsg.h
index 01d99ac705271c414b0be23082ed2019ad1f9df8..ab0203adf869c57730099a4e51a089ecca279d50 100644
--- a/include/common/tmsg.h
+++ b/include/common/tmsg.h
@@ -2259,11 +2259,11 @@ typedef struct {
 typedef struct {
   char   name[TSDB_STREAM_FNAME_LEN];
   int8_t igNotExists;
-} SMDropStreamTaskReq;
+} SMDropStreamReq;
 
 typedef struct {
   int8_t reserved;
-} SMDropStreamTaskRsp;
+} SMDropStreamRsp;
 
 typedef struct {
   SMsgHead head;
diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c
index 0d5bc9b021fc45651cc1944fa16cc01533d0b7da..3a42c694c849fd1d03350f87f4f2d086d589d7bf 100644
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@@ -679,7 +679,7 @@ static int32_t mndProcessDropStreamReq(SRpcMsg *pReq) {
   /*SDbObj     *pDb = NULL;*/
   /*SUserObj   *pUser = NULL;*/
 
-  SMDropStreamTaskReq dropReq = *(SMDropStreamTaskReq *)pReq->pCont;
+  SMDropStreamReq dropReq = *(SMDropStreamReq *)pReq->pCont;
 
   pStream = mndAcquireStream(pMnode, dropReq.name);