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

Merge pull request #24064 from taosdata/fix/TD-27803 

fix:[TD-27803]process commit logic if manual commit in the end
This commit is contained in:
Haojun Liao 2023-12-15 09:18:20 +08:00 committed by GitHub
parent bf3bfa4d66 4346d6ef5d
commit c113624195
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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");
} }