fill state

ae117bd7 · liuyao · 53857abe · ae117bd7
隐藏空白更改
内联并排

Showing with 4 addition and 2 deletion

source/libs/stream/src/streamState.c source/libs/stream/src/streamState.c +4 -2

未找到文件。
--- a/source/libs/stream/src/streamState.c
+++ b/source/libs/stream/src/streamState.c
@@ -256,8 +256,10 @@ int32_t streamStateBegin(SStreamState* pState) {

 int32_t streamStateCommit(SStreamState* pState) {
 #ifdef USE_ROCKSDB
-  SStreamSnapshot* pShot = getSnapshot(pState->pFileState);
-  flushSnapshot(pState->pFileState, pShot, true);
+  if (pState->pFileState) {
+    SStreamSnapshot* pShot = getSnapshot(pState->pFileState);
+    flushSnapshot(pState->pFileState, pShot, true);
+  }
  return 0;
 #else
  if (tdbCommit(pState->pTdbState->db, pState->pTdbState->txn) < 0) {