xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix:[TD-27803]process commit logic if manual commit in the end

This commit is contained in:
wangmm0220 2023-12-14 14:59:30 +08:00
parent 2e35b42a16
commit 4346d6ef5d
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
utils/test/c/tmqSim.c
View File

@ -906,6 +906,7 @@ void* consumeThreadFunc(void* param) {
pPrint("tmq_commit() manual commit when consume end.\n"); pPrint("tmq_commit() manual commit when consume end.\n");
/*tmq_commit(pInfo->tmq, NULL, 0);*/ /*tmq_commit(pInfo->tmq, NULL, 0);*/
tmq_commit_sync(pInfo->tmq, NULL); tmq_commit_sync(pInfo->tmq, NULL);
tmq_commit_cb_print(pInfo->tmq, 0, pInfo);
taosFprintfFile(g_fp, "tmq_commit() manual commit over.\n"); taosFprintfFile(g_fp, "tmq_commit() manual commit over.\n");
pPrint("tmq_commit() manual commit over.\n"); pPrint("tmq_commit() manual commit over.\n");
} }