From 832aed5e980bee12bcbc068e3e42244597bb2836 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Sun, 25 Jun 2023 17:10:59 +0800 Subject: [PATCH] add checkpoint --- source/libs/stream/src/streamSnapshot.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/libs/stream/src/streamSnapshot.c b/source/libs/stream/src/streamSnapshot.c index ff854e4a2e..d6dd4dccc8 100644 --- a/source/libs/stream/src/streamSnapshot.c +++ b/source/libs/stream/src/streamSnapshot.c @@ -285,6 +285,7 @@ int32_t streamSnapWrite(SStreamSnapWriter* pWriter, uint8_t* pData, uint32_t nDa taosArrayPush(handle->pFileList, &item); handle->fd = taosOpenFile(taosArrayGet(handle->pFileList, taosArrayGetSize(handle->pFileList) - 1), TD_FILE_WRITE); + taosWriteFile(handle->fd, pHdr->data, pHdr->size); handle->currFileIdx += 1; }