diff --git a/source/libs/stream/src/streamState.c b/source/libs/stream/src/streamState.c
index 218d906504..a368707cb1 100644
--- a/source/libs/stream/src/streamState.c
+++ b/source/libs/stream/src/streamState.c
@@ -757,7 +757,7 @@ int32_t streamStateSessionDel(SStreamState* pState, const SSessionKey* key) {
 #ifdef USE_ROCKSDB
   qDebug("===stream===delete skey:%" PRId64 ", ekey:%" PRId64 ", groupId:%" PRIu64, key->win.skey, key->win.ekey,
          key->groupId);
-  return streamStateSessionDel_rocksdb(pState, key);
+  return deleteRowBuff(pState->pFileState, key, sizeof(SSessionKey));
 #else
   SStateSessionKey sKey = {.key = *key, .opNum = pState->number};
   return tdbTbDelete(pState->pTdbState->pSessionStateDb, &sKey, sizeof(SStateSessionKey), pState->pTdbState->txn);