diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index f7638a42ae7d79addd638f68b8601bdbc9161579..f7a8ec4564b53a8c65b3d1de98b97417cb388fd3 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -92,6 +92,7 @@ void* streamBackendInit(const char* path) {
   rocksdb_options_set_recycle_log_file_num(opts, 6);
   rocksdb_options_set_max_write_buffer_number(opts, 2);
   rocksdb_options_set_info_log_level(opts, 0);
+  rocksdb_options_set_db_write_buffer_size(opts, 256 << 20);
 
   pHandle->env = env;
   pHandle->dbOpt = opts;