From f08a183ab597d2108aa31e1755f0395726381d1c Mon Sep 17 00:00:00 2001
From: Shengliang Guan <slguan@taosdata.com>
Date: Sun, 27 Nov 2022 15:39:01 +0800
Subject: [PATCH] test: fsync consum file

---
 utils/test/c/tmqSim.c | 3 +++
 1 file changed, 3 insertions(+)

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) {