diff --git a/source/libs/stream/CMakeLists.txt b/source/libs/stream/CMakeLists.txt
index 2edbc44aaeb8e87c0dc51971a4c92c292549a87b..e870798a7784276d5e85fa0b469d7febf68e2fb5 100644
--- a/source/libs/stream/CMakeLists.txt
+++ b/source/libs/stream/CMakeLists.txt
@@ -10,7 +10,7 @@ if(${BUILD_WITH_ROCKSDB})
   target_link_libraries(
     stream
     PUBLIC rocksdb tdb
-    PRIVATE  os util transport qcom executor wal
+    PRIVATE  os util qcom executor wal
   )
 
   target_include_directories(
diff --git a/source/libs/stream/src/streamStateRocksdb.c b/source/libs/stream/src/streamStateRocksdb.c
index 4fae927ac9c7dc312e3f092806bb209445c6ef34..3f2c2426a3f36d18dff54b873150c08ff52368c1 100644
--- a/source/libs/stream/src/streamStateRocksdb.c
+++ b/source/libs/stream/src/streamStateRocksdb.c
@@ -362,7 +362,7 @@ int streamInitBackend(SStreamState* pState, char* path) {
   //   create the DB if it's not already present
   rocksdb_options_set_create_if_missing(opts, 1);
   rocksdb_options_set_create_missing_column_families(opts, 1);
-  rocksdb_options_set_write_buffer_size(opts, 128 << 20);
+  rocksdb_options_set_write_buffer_size(opts, 16 << 20);
 
   char* err = NULL;
   int   cfLen = sizeof(ginitDict) / sizeof(ginitDict[0]);
@@ -373,7 +373,7 @@ int streamInitBackend(SStreamState* pState, char* path) {
     cfOpt[i] = rocksdb_options_create_copy(opts);
     // refactor later
     rocksdb_block_based_table_options_t* tableOpt = rocksdb_block_based_options_create();
-    rocksdb_cache_t*                     cache = rocksdb_cache_create_lru(128 << 20);
+    rocksdb_cache_t*                     cache = rocksdb_cache_create_lru(32 << 20);
     rocksdb_block_based_options_set_block_cache(tableOpt, cache);
 
     rocksdb_filterpolicy_t* filter = rocksdb_filterpolicy_create_bloom(15);