diff --git a/source/libs/stream/src/streamState.c b/source/libs/stream/src/streamState.c
index 93442790a4..4c65f403a9 100644
--- a/source/libs/stream/src/streamState.c
+++ b/source/libs/stream/src/streamState.c
@@ -419,19 +419,16 @@ void streamStateSetNumber(SStreamState* pState, int32_t number) { pState->number
 int32_t streamStateSaveInfo(SStreamState* pState, void* pKey, int32_t keyLen, void* pVal, int32_t vLen) {
 #ifdef USE_ROCKSDB
   int32_t code = 0;
-  void*   batch = streamStateCreateBatch();
 
-  code = streamStatePutBatch(pState, "default", batch, pKey, pVal, vLen, 0);
+  char* cfName = "default";
+  void* batch = streamStateCreateBatch();
+  code = streamStatePutBatch(pState, cfName, batch, pKey, pVal, vLen, 0);
   if (code != 0) {
     streamStateDestroyBatch(batch);
     return code;
   }
   code = streamStatePutBatch_rocksdb(pState, batch);
   streamStateDestroyBatch(batch);
-  // code = streamDefaultPut_rocksdb(pState, pKey, pVal, vLen);
-  //  char*   Val = NULL;
-  //  int32_t len = 0;
-  //  code = streamDefaultGet_rocksdb(pState, pKey, (void**)&Val, &len);
   return code;
 #else
   return 0;
@@ -707,7 +704,7 @@ int32_t streamStateSessionPut(SStreamState* pState, const SSessionKey* key, void
 #ifdef USE_ROCKSDB
   SRowBuffPos* pos = (SRowBuffPos*)value;
   if (pos->needFree) {
-    int32_t      code = streamStateSessionPut_rocksdb(pState, key, pos->pRowBuff, vLen);
+    int32_t code = streamStateSessionPut_rocksdb(pState, key, pos->pRowBuff, vLen);
     streamStateReleaseBuf(pState, pos, true);
     qDebug("===stream===save skey:%" PRId64 ", ekey:%" PRId64 ", groupId:%" PRIu64 ".code:%d", key->win.skey,
            key->win.ekey, key->groupId, code);