From 4346d6ef5d475d783945a02655a374798f3158fd Mon Sep 17 00:00:00 2001 From: wangmm0220 Date: Thu, 14 Dec 2023 14:59:30 +0800 Subject: [PATCH] fix:[TD-27803]process commit logic if manual commit in the end --- utils/test/c/tmqSim.c | 1 + 1 file changed, 1 insertion(+) diff --git a/utils/test/c/tmqSim.c b/utils/test/c/tmqSim.c index 14e30008fe..006bd516d0 100644 --- a/utils/test/c/tmqSim.c +++ b/utils/test/c/tmqSim.c @@ -906,6 +906,7 @@ void* consumeThreadFunc(void* param) { pPrint("tmq_commit() manual commit when consume end.\n"); /*tmq_commit(pInfo->tmq, NULL, 0);*/ tmq_commit_sync(pInfo->tmq, NULL); + tmq_commit_cb_print(pInfo->tmq, 0, pInfo); taosFprintfFile(g_fp, "tmq_commit() manual commit over.\n"); pPrint("tmq_commit() manual commit over.\n"); }