test: fsync consum file
This commit is contained in:
parent
8d1b036253
commit
f08a183ab5
|
@ -865,6 +865,9 @@ void loop_consume(SThreadInfo* pInfo) {
|
||||||
|
|
||||||
taosFprintfFile(g_fp, "==== consumerId: %d, consumeMsgCnt: %" PRId64 ", consumeRowCnt: %" PRId64 "\n",
|
taosFprintfFile(g_fp, "==== consumerId: %d, consumeMsgCnt: %" PRId64 ", consumeRowCnt: %" PRId64 "\n",
|
||||||
pInfo->consumerId, pInfo->consumeMsgCnt, pInfo->consumeRowCnt);
|
pInfo->consumerId, pInfo->consumeMsgCnt, pInfo->consumeRowCnt);
|
||||||
|
|
||||||
|
taosFsyncFile(pInfo->pConsumeRowsFile);
|
||||||
|
taosCloseFile(&pInfo->pConsumeRowsFile);
|
||||||
}
|
}
|
||||||
|
|
||||||
void* consumeThreadFunc(void* param) {
|
void* consumeThreadFunc(void* param) {
|
||||||
|
|
Loading…
Reference in New Issue