diff --git a/src/common/inc/tglobal.h b/src/common/inc/tglobal.h
index 2f4aa4c2b2ad0822fcf7a45987b812376fe5d9f0..abb4d39ee1ac945868dc42c14acefd9f8d4a6768 100644
--- a/src/common/inc/tglobal.h
+++ b/src/common/inc/tglobal.h
@@ -142,6 +142,7 @@ extern int32_t tsMonitorInterval;
 extern int8_t tsEnableStream;
 
 // internal
+extern int8_t  tsCompactMnodeWal;
 extern int8_t  tsPrintAuth;
 extern int8_t  tscEmbedded;
 extern char    configDir[];
diff --git a/src/common/src/tglobal.c b/src/common/src/tglobal.c
index db97c3a5af3e804316c60419bea3f2095f89b53c..ab036b021cebbe9de16f3516ca75b184157d783c 100644
--- a/src/common/src/tglobal.c
+++ b/src/common/src/tglobal.c
@@ -176,6 +176,7 @@ int32_t tsMonitorInterval = 30;  // seconds
 int8_t  tsEnableStream = 1;
 
 // internal
+int8_t tsCompactMnodeWal = 0;
 int8_t tsPrintAuth = 0;
 int8_t tscEmbedded = 0;
 char   configDir[TSDB_FILENAME_LEN] = {0};
diff --git a/src/dnode/src/dnodeMain.c b/src/dnode/src/dnodeMain.c
index 410e6bb1888a11858e5d091f3f82c54df4dc2022..48680e20d9d199cac154d1a666397605bedb9ef2 100644
--- a/src/dnode/src/dnodeMain.c
+++ b/src/dnode/src/dnodeMain.c
@@ -40,6 +40,7 @@
 #include "dnodeShell.h"
 #include "dnodeTelemetry.h"
 #include "module.h"
+#include "mnode.h"
 
 #if !defined(_MODULE) || !defined(_TD_LINUX)
 int32_t moduleStart() { return 0; }
diff --git a/src/dnode/src/dnodeSystem.c b/src/dnode/src/dnodeSystem.c
index e49b3eba99408c9453189106dc6f01e0d0afc7fe..ee37ffdcbb90f710253d051f1d4895ee8bc26dea 100644
--- a/src/dnode/src/dnodeSystem.c
+++ b/src/dnode/src/dnodeSystem.c
@@ -42,6 +42,8 @@ int32_t main(int32_t argc, char *argv[]) {
       }
     } else if (strcmp(argv[i], "-C") == 0) {
       dump_config = 1;
+    } else if (strcmp(argv[i], "--compact-mnode-wal") == 0) {
+      tsCompactMnodeWal = 1;
     } else if (strcmp(argv[i], "-V") == 0) {
 #ifdef _ACCT
       char *versionStr = "enterprise";
diff --git a/src/inc/mnode.h b/src/inc/mnode.h
index 2495a42ba2e5d23cb361e2d64de04d1f710764ea..c66dc60a1bc4daac33ec18c8033bb43a3b379b41 100644
--- a/src/inc/mnode.h
+++ b/src/inc/mnode.h
@@ -73,6 +73,8 @@ int32_t mnodeProcessPeerReq(SMnodeMsg *pMsg);
 void    mnodeProcessPeerRsp(SRpcMsg *pMsg);
 int32_t mnodeRetriveAuth(char *user, char *spi, char *encrypt, char *secret, char *ckey);
 
+int32_t mnodeCompactWal();
+
 #ifdef __cplusplus
 }
 #endif
diff --git a/src/mnode/inc/mnodeSdb.h b/src/mnode/inc/mnodeSdb.h
index e4e4a7a054ff194a578dbaad75b2ae17bfe6f1ad..13dd8bd06b7c44fe235e13c264a9c72f3a117d53 100644
--- a/src/mnode/inc/mnodeSdb.h
+++ b/src/mnode/inc/mnodeSdb.h
@@ -106,6 +106,7 @@ int32_t  sdbGetId(void *pTable);
 uint64_t sdbGetVersion();
 bool     sdbCheckRowDeleted(void *pTable, void *pRow);
 
+int32_t mnodeCompactWal();
 #ifdef __cplusplus
 }
 #endif
diff --git a/src/mnode/src/mnodeMain.c b/src/mnode/src/mnodeMain.c
index 7ef0488c420dd470c3afc5d7ca8ac7a518ccdc73..76eebe0d01472b60ae348a8ca61a1a32384016a6 100644
--- a/src/mnode/src/mnodeMain.c
+++ b/src/mnode/src/mnodeMain.c
@@ -57,6 +57,12 @@ static SStep tsMnodeSteps[] = {
   {"show",    mnodeInitShow,    mnodeCleanUpShow}
 };
 
+/*
+static SStep tsMnodeCompactSteps[] = {
+  {"cluster", mnodeInitCluster, NULL},
+};
+*/
+
 static void mnodeInitTimer();
 static void mnodeCleanupTimer();
 static bool mnodeNeedStart() ;
diff --git a/src/mnode/src/mnodeSdb.c b/src/mnode/src/mnodeSdb.c
index 505d3c519c6d659d32eb2dfe3f18f50757a0a0de..64c771316476cf6b5f1dabd0fc01b1b921928a6f 100644
--- a/src/mnode/src/mnodeSdb.c
+++ b/src/mnode/src/mnodeSdb.c
@@ -450,6 +450,12 @@ int32_t sdbInit() {
   }
 
   tsSdbMgmt.status = SDB_STATUS_SERVING;
+
+  if (tsCompactMnodeWal) {
+    mnodeCompactWal();
+    exit(EXIT_SUCCESS);
+  }
+
   return TSDB_CODE_SUCCESS;
 }
 
@@ -1138,3 +1144,9 @@ static void *sdbWorkerFp(void *pWorker) {
 int32_t sdbGetReplicaNum() {
   return tsSdbMgmt.cfg.replica;
 }
+
+int32_t mnodeCompactWal() {
+  sdbInfo("vgId:1, start compact mnode wal...");
+
+  return 0;
+}
\ No newline at end of file