diff --git a/utils/test/c/tmqSim.c b/utils/test/c/tmqSim.c
index f77a910f35..fe2bb59af3 100644
--- a/utils/test/c/tmqSim.c
+++ b/utils/test/c/tmqSim.c
@@ -865,6 +865,9 @@ void loop_consume(SThreadInfo* pInfo) {
 
   taosFprintfFile(g_fp, "==== consumerId: %d, consumeMsgCnt: %" PRId64 ", consumeRowCnt: %" PRId64 "\n",
                   pInfo->consumerId, pInfo->consumeMsgCnt, pInfo->consumeRowCnt);
+                  
+  taosFsyncFile(pInfo->pConsumeRowsFile);
+  taosCloseFile(&pInfo->pConsumeRowsFile);
 }
 
 void* consumeThreadFunc(void* param) {