add checkpoint

832aed5e · yihaoDeng · 0330f3b2 · 832aed5e
隐藏空白更改
内联并排

Showing with 1 addition and 0 deletion

source/libs/stream/src/streamSnapshot.c source/libs/stream/src/streamSnapshot.c +1 -0

未找到文件。
--- 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;
  }