diff --git a/src/tsdb/src/tsdbFile.c b/src/tsdb/src/tsdbFile.c
index 626ad77da2eab4be9e94516c4e5c7c0e5a45837e..559fb0c2332c8d48fcfe5ca3ff249d710a1da7c5 100644
--- a/src/tsdb/src/tsdbFile.c
+++ b/src/tsdb/src/tsdbFile.c
@@ -79,7 +79,7 @@ int tsdbOpenFileH(STsdbRepo *pRepo) {
   DIR *   dir = NULL;
   int     fid = 0;
   int     vid = 0;
-  regex_t regex1, regex2;
+  regex_t regex1 = {0}, regex2 = {0};
   int     code = 0;
   char    fname[TSDB_FILENAME_LEN] = "\0";
 
@@ -95,9 +95,24 @@ int tsdbOpenFileH(STsdbRepo *pRepo) {
 
   dir = opendir(tDataDir);
   if (dir == NULL) {
-    tsdbError("vgId:%d failed to open directory %s since %s", REPO_ID(pRepo), tDataDir, strerror(errno));
-    terrno = TAOS_SYSTEM_ERROR(errno);
-    goto _err;
+    if (errno == ENOENT) {
+      if (taosMkDir(tDataDir, 0755) < 0) {
+        tsdbError("vgId:%d failed to create directory %s since %s", REPO_ID(pRepo), tDataDir, strerror(errno));
+        terrno = TAOS_SYSTEM_ERROR(errno);
+        goto _err;
+      }
+
+      dir = opendir(tDataDir);
+      if (dir == NULL) {
+        tsdbError("vgId:%d failed to open directory %s since %s", REPO_ID(pRepo), tDataDir, strerror(errno));
+        terrno = TAOS_SYSTEM_ERROR(errno);
+        goto _err;
+      }
+    } else {
+      tsdbError("vgId:%d failed to open directory %s since %s", REPO_ID(pRepo), tDataDir, strerror(errno));
+      terrno = TAOS_SYSTEM_ERROR(errno);
+      goto _err;
+    }
   }
 
   code = regcomp(&regex1, "^v[0-9]+f[0-9]+\\.(head|data|last|stat)$", REG_EXTENDED);