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

fix stream transfer err

This commit is contained in:
yihaoDeng 2023-11-08 14:57:20 +08:00
parent 2e7d041e0a
commit 7e03fa6664
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/libs/stream/src/streamSnapshot.c
View File

@ -148,6 +148,7 @@ int32_t streamSnapHandleInit(SStreamSnapHandle* pHandle, char* path, int64_t chk
taosMemoryFree(tdir); taosMemoryFree(tdir);
return code; return code;
} }
pHandle->delFlag = 1;
chkpId = 0; chkpId = 0;
} }
@ -308,7 +309,6 @@ int32_t streamSnapReaderOpen(void* pMeta, int64_t sver, int64_t chkpId, char* pa
taosMemoryFree(pReader); taosMemoryFree(pReader);
return -1; return -1;
} }
pReader->handle.delFlag = 1;
*ppReader = pReader; *ppReader = pReader;