diff --git a/source/libs/stream/src/streamStateRocksdb.c b/source/libs/stream/src/streamStateRocksdb.c index 053ce492a817fea1e15c0e8a2d26580dbf398b9a..ee9a3824c0fa297e0fa6e74565543921b6f7b320 100644 --- a/source/libs/stream/src/streamStateRocksdb.c +++ b/source/libs/stream/src/streamStateRocksdb.c @@ -352,8 +352,8 @@ const char* comparePartagKeyName(void* name) { return ginitDict[6].key; } int streamInitBackend(SStreamState* pState, char* path) { rocksdb_env_t* env = rocksdb_create_default_env(); // rocksdb_envoptions_create(); - rocksdb_env_set_low_priority_background_threads(env, 15); - rocksdb_env_set_high_priority_background_threads(env, 5); + rocksdb_env_set_low_priority_background_threads(env, 4); + rocksdb_env_set_high_priority_background_threads(env, 2); rocksdb_options_t* opts = rocksdb_options_create(); rocksdb_options_set_env(opts, env);