diff --git a/source/dnode/vnode/src/tq/tqOffset.c b/source/dnode/vnode/src/tq/tqOffset.c
index 5e67f3c3ac..21faf19805 100644
--- a/source/dnode/vnode/src/tq/tqOffset.c
+++ b/source/dnode/vnode/src/tq/tqOffset.c
@@ -119,6 +119,7 @@ STqOffsetStore* tqOffsetOpen(STQ* pTq) {
 }
 
 void tqOffsetClose(STqOffsetStore* pStore) {
+  if(pStore == NULL) return;
   tqOffsetCommitFile(pStore);
   taosHashCleanup(pStore->pHash);
   taosMemoryFree(pStore);