From 273057cfaca8a7c4a3d3474d99d6cf9979940779 Mon Sep 17 00:00:00 2001
From: plum-lihui <huili@taosdata.com>
Date: Sat, 11 Jun 2022 21:16:00 +0800
Subject: [PATCH] test: log rows from per vgroup

---
 tests/test/c/tmqSim.c | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/tests/test/c/tmqSim.c b/tests/test/c/tmqSim.c
index 2bd9a2e471..2710a00a72 100644
--- a/tests/test/c/tmqSim.c
+++ b/tests/test/c/tmqSim.c
@@ -537,6 +537,12 @@ void* consumeThreadFunc(void* param) {
   // save consume result into consumeresult table
   saveConsumeResult(pInfo);
 
+  // save rows from per vgroup
+  taosFprintfFile(g_fp, "======== consumerId: %d, consume rows from per vgroups ========\n", pInfo->consumerId);
+  for (int32_t i = 0; i < pInfo->numOfVgroups; i++) {
+    taosFprintfFile(g_fp, "vgroups: %04d, rows: %d\n", pInfo->rowsOfPerVgroups[i][0], pInfo->rowsOfPerVgroups[i][1]);
+  }
+
   return NULL;
 }