diff --git a/source/dnode/vnode/impl/src/vnodeMain.c b/source/dnode/vnode/impl/src/vnodeMain.c
index fb0106ab0a..59e3bae5d7 100644
--- a/source/dnode/vnode/impl/src/vnodeMain.c
+++ b/source/dnode/vnode/impl/src/vnodeMain.c
@@ -109,7 +109,7 @@ static int vnodeOpenImpl(SVnode *pVnode) {
   }
 
   // TODO: Open TQ
-  sprintf(dir, "%s/wal", pVnode->path);
+  sprintf(dir, "%s/tq", pVnode->path);
   pVnode->pTq = tqOpen(dir, &(pVnode->config.tqCfg), NULL, NULL);
   if (pVnode->pTq == NULL) {
     // TODO: handle error