diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index 16ba81c74a610c761d6ad697b14a2db2ff5cba24..f9a9bef9601025f0679000d5fef02b0a923d268c 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -86,10 +86,10 @@ void* streamBackendInit(const char* path) {
   rocksdb_options_set_env(opts, env);
   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_max_total_wal_size(opts, 128 << 20);
+  rocksdb_options_set_write_buffer_size(opts, 64 << 20);
+  rocksdb_options_set_max_total_wal_size(opts, 64 << 20);
   rocksdb_options_set_recycle_log_file_num(opts, 6);
-  rocksdb_options_set_max_write_buffer_number(opts, 3);
+  rocksdb_options_set_max_write_buffer_number(opts, 2);
   rocksdb_options_set_info_log_level(opts, 0);
 
   pHandle->env = env;
@@ -740,7 +740,7 @@ int32_t streamStateOpenBackendCf(void* backend, char* name, SHashObj* ids) {
     qError("failed to open rocksdb cf, reason:%s", err);
     taosMemoryFree(err);
   } else {
-    qDebug("succ to open rocksdb cf, reason:%s", err);
+    qDebug("succ to open rocksdb cf, reason");
   }
 
   pIter = taosHashIterate(ids, NULL);