diff --git a/include/common/tmsg.h b/include/common/tmsg.h
index f148009f81aa301d827f7a2595f39b8b2297fceb..67fadf7c49d090f8744dcdf7119e2e519fe88eda 100644
--- a/include/common/tmsg.h
+++ b/include/common/tmsg.h
@@ -1920,13 +1920,14 @@ typedef struct {
 } SVCreateTSmaReq;
 
 typedef struct {
-  int8_t      type;                            // 0 status report, 1 update data
-  char        indexName[TSDB_INDEX_NAME_LEN];  //
-  STimeWindow windows;
+  int8_t  type;  // 0 status report, 1 update data
+  int64_t indexUid;
+  int64_t skey;  // start TS key of interval/sliding window
 } STSmaMsg;
 
 typedef struct {
   int64_t ver;  // use a general definition
+  int64_t indexUid;
   char    indexName[TSDB_INDEX_NAME_LEN];
 } SVDropTSmaReq;
 
diff --git a/source/common/src/tmsg.c b/source/common/src/tmsg.c
index 9472b19ccaeb76eac073a0954482b7d47669263c..44dd8f6a055e6d94f89fa3c263bdb3458b4ecc76 100644
--- a/source/common/src/tmsg.c
+++ b/source/common/src/tmsg.c
@@ -2641,12 +2641,14 @@ int32_t tSerializeSVDropTSmaReq(void **buf, SVDropTSmaReq *pReq) {
   int32_t tlen = 0;
 
   tlen += taosEncodeFixedI64(buf, pReq->ver);
+  tlen += taosEncodeFixedI64(buf, pReq->indexUid);
   tlen += taosEncodeString(buf, pReq->indexName);
 
   return tlen;
 }
 void *tDeserializeSVDropTSmaReq(void *buf, SVDropTSmaReq *pReq) {
   buf = taosDecodeFixedI64(buf, &(pReq->ver));
+  buf = taosDecodeFixedI64(buf, &(pReq->indexUid));
   buf = taosDecodeStringTo(buf, pReq->indexName);
 
   return buf;