From 52f588955bbaaa2e4bbc9a1b475e7ac2de6d3e87 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Sun, 25 Jun 2023 20:05:42 +0800 Subject: [PATCH] add checkpoint --- source/libs/stream/src/streamSnapshot.c | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/source/libs/stream/src/streamSnapshot.c b/source/libs/stream/src/streamSnapshot.c index 4d116efe0f..7b0c832665 100644 --- a/source/libs/stream/src/streamSnapshot.c +++ b/source/libs/stream/src/streamSnapshot.c @@ -242,11 +242,8 @@ int32_t streamSnapRead(SStreamSnapReader* pReader, uint8_t** ppData, int64_t* si return 0; } item = taosArrayGet(pHandle->pFileList, pHandle->currFileIdx); - - pHandle->offset = 0; pHandle->fd = taosOpenFile(item->name, TD_FILE_READ); - // handle err later - nread = taosReadFile(pHandle->fd, buf + sizeof(SStreamSnapBlockHdr), kBlockSize); + nread = taosPReadFile(pHandle->fd, buf + sizeof(SStreamSnapBlockHdr), kBlockSize, pHandle->offset); pHandle->offset += nread; }