From 7e4eefcde18c7936fbbf6a569f2e0a462708e121 Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Wed, 12 Apr 2023 05:50:01 +0000
Subject: [PATCH] fix write crash

---
 source/libs/stream/src/tstreamFileState.c | 1 +
 1 file changed, 1 insertion(+)

diff --git a/source/libs/stream/src/tstreamFileState.c b/source/libs/stream/src/tstreamFileState.c
index ddd8e148ff..c3b9d9f7dd 100644
--- a/source/libs/stream/src/tstreamFileState.c
+++ b/source/libs/stream/src/tstreamFileState.c
@@ -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";