diff --git a/source/libs/tkv/src/tDiskMgr.c b/source/libs/tkv/src/tDiskMgr.c
index d759171f853b5077caa36de814535e63a8faaa3a..c8ce3c6c2a87d1e0c0bb9c4a291e23695074ef26 100644
--- a/source/libs/tkv/src/tDiskMgr.c
+++ b/source/libs/tkv/src/tDiskMgr.c
@@ -25,12 +25,35 @@ struct SDiskMgr {
 #define PAGE_OFFSET(PGID, PGSIZE) ((PGID) * (PGSIZE))
 
 int tdmOpen(SDiskMgr **ppDiskMgr, const char *fname, uint16_t pgsize) {
-  // TODO
+  SDiskMgr *pDiskMgr;
+
+  pDiskMgr = malloc(sizeof(*pDiskMgr));
+  if (pDiskMgr == NULL) {
+    return -1;
+  }
+
+  pDiskMgr->fname = strdup(fname);
+  if (pDiskMgr->fname == NULL) {
+    free(pDiskMgr);
+    return -1;
+  }
+  pDiskMgr->pgsize = pgsize;
+  pDiskMgr->fd = open(fname, O_CREAT | O_RDWR, 0755);
+  if (pDiskMgr->fd < 0) {
+    free(pDiskMgr->fname);
+    free(pDiskMgr);
+    return -1;
+  }
+
+  *ppDiskMgr = pDiskMgr;
+
   return 0;
 }
 
 int tdmClose(SDiskMgr *pDiskMgr) {
-  // TODO
+  close(pDiskMgr->fd);
+  free(pDiskMgr->fname);
+  free(pDiskMgr);
   return 0;
 }