fix write crash
This commit is contained in:
parent
ed4aaade8c
commit
7e4eefcde1
|
@ -355,6 +355,7 @@ int32_t flushSnapshot(SStreamFileState* pFileState, SStreamSnapshot* pSnapshot,
|
|||
if (streamStateGetBatchSize(batch) > 0) {
|
||||
code = streamStatePutBatch_rocksdb(pFileState->pFileStore, batch);
|
||||
}
|
||||
streamStateClearBatch(batch);
|
||||
|
||||
if (flushState) {
|
||||
const char* taskKey = "streamFileState";
|
||||
|
|
Loading…
Reference in New Issue