From 82df77eba8b6bed1e0a9f0471f3e60d9f4126439 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Thu, 20 Jul 2023 11:52:31 +0000 Subject: [PATCH] fix stream state transfer --- source/libs/stream/src/streamSnapshot.c | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamSnapshot.c b/source/libs/stream/src/streamSnapshot.c index 086da597f6..a036bcd877 100644 --- a/source/libs/stream/src/streamSnapshot.c +++ b/source/libs/stream/src/streamSnapshot.c @@ -157,7 +157,9 @@ int32_t streamSnapHandleInit(SStreamSnapHandle* pHandle, char* path, int64_t chk // current item.name = pFile->pCurrent; item.type = ROCKSDB_CURRENT_TYPE; - taosStatFile(pFile->pCurrent, &item.size, NULL); + if (taosStatFile(pFile->pCurrent, &item.size, NULL) != 0) { + qError("stream-state failed to get file size: %s", pFile->pCurrent); + } taosArrayPush(list, &item); // mainfest item.name = pFile->pMainfest;