diff --git a/source/libs/stream/src/streamStateRocksdb.c b/source/libs/stream/src/streamStateRocksdb.c
index 5c5f5020ff..fc354952a9 100644
--- a/source/libs/stream/src/streamStateRocksdb.c
+++ b/source/libs/stream/src/streamStateRocksdb.c
@@ -310,20 +310,18 @@ int streamInitBackend(SStreamState* pState, char* path) {
   const rocksdb_options_t** cfOpt = taosMemoryCalloc(cfLen, sizeof(rocksdb_options_t*));
   for (int i = 0; i < cfLen; i++) {
     cfOpt[i] = rocksdb_options_create_copy(opts);
-  };
-
-  {
     rocksdb_block_based_table_options_t* tableOpt = rocksdb_block_based_options_create();
     rocksdb_cache_t*                     cache = rocksdb_cache_create_lru(128 << 20);
     rocksdb_block_based_options_set_block_cache(tableOpt, cache);
-    rocksdb_filterpolicy_t* filter = rocksdb_filterpolicy_create_bloom_full(20);
 
+    rocksdb_filterpolicy_t* filter = rocksdb_filterpolicy_create_bloom(15);
     rocksdb_block_based_options_set_filter_policy(tableOpt, filter);
-    rocksdb_options_set_block_based_table_factory((rocksdb_options_t*)opts, tableOpt);
+
+    rocksdb_options_set_block_based_table_factory((rocksdb_options_t*)cfOpt[i], tableOpt);
 
     rocksdb_slicetransform_t* trans = rocksdb_slicetransform_create_fixed_prefix(8);
-    rocksdb_options_set_prefix_extractor((rocksdb_options_t*)opts, trans);
-  }
+    rocksdb_options_set_prefix_extractor((rocksdb_options_t*)cfOpt[i], trans);
+  };
 
   rocksdb_comparator_t** pCompare = taosMemoryCalloc(cfLen, sizeof(rocksdb_comparator_t**));