diff --git a/src/tsdb/src/tsdbCommit.c b/src/tsdb/src/tsdbCommit.c
index 650a32eede7a49c26acb3c908f9376e3a0e7ac64..637b02cd32ae8ad8e4077684609dcac23922d8a0 100644
--- a/src/tsdb/src/tsdbCommit.c
+++ b/src/tsdb/src/tsdbCommit.c
@@ -282,7 +282,7 @@ static int tsdbCommitToFile(STsdbRepo *pRepo, int fid, SCommitIter *iters, SRWHe
 
 _err:
   tfree(dataDir);
-  tsdbCloseHelperFile(pHelper, 1, NULL);
+  tsdbCloseHelperFile(pHelper, 1, pGroup);
   return -1;
 }