thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-24 08:32:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

disable rocksdb

Browse Source
This commit is contained in:
Han Fei 2024-07-10 13:01:15 +00:00
parent 027c855fcb
commit 0c843ae146
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Coordination/CoordinationSettings.h
View File

@ -55,7 +55,7 @@ struct Settings;
M(UInt64, min_request_size_for_cache, 50 * 1024, "Minimal size of the request to cache the deserialization result. Caching can have negative effect on latency for smaller requests, set to 0 to disable", 0) \ M(UInt64, min_request_size_for_cache, 50 * 1024, "Minimal size of the request to cache the deserialization result. Caching can have negative effect on latency for smaller requests, set to 0 to disable", 0) \
M(UInt64, raft_limits_reconnect_limit, 50, "If connection to a peer is silent longer than this limit * (multiplied by heartbeat interval), we re-establish the connection.", 0) \ M(UInt64, raft_limits_reconnect_limit, 50, "If connection to a peer is silent longer than this limit * (multiplied by heartbeat interval), we re-establish the connection.", 0) \
M(Bool, async_replication, false, "Enable async replication. All write and read guarantees are preserved while better performance is achieved. Settings is disabled by default to not break backwards compatibility.", 0) \ M(Bool, async_replication, false, "Enable async replication. All write and read guarantees are preserved while better performance is achieved. Settings is disabled by default to not break backwards compatibility.", 0) \
M(Bool, use_rocksdb, true, "Use rocksdb as backend storage", 0) \ M(Bool, experimental_use_rocksdb, false, "Use rocksdb as backend storage", 0) \
M(UInt64, latest_logs_cache_size_threshold, 1 * 1024 * 1024 * 1024, "Maximum total size of in-memory cache of latest log entries.", 0) \ M(UInt64, latest_logs_cache_size_threshold, 1 * 1024 * 1024 * 1024, "Maximum total size of in-memory cache of latest log entries.", 0) \
M(UInt64, commit_logs_cache_size_threshold, 500 * 1024 * 1024, "Maximum total size of in-memory cache of log entries needed next for commit.", 0) \ M(UInt64, commit_logs_cache_size_threshold, 500 * 1024 * 1024, "Maximum total size of in-memory cache of log entries needed next for commit.", 0) \
M(UInt64, disk_move_retries_wait_ms, 1000, "How long to wait between retries after a failure which happened while a file was being moved between disks.", 0) \ M(UInt64, disk_move_retries_wait_ms, 1000, "How long to wait between retries after a failure which happened while a file was being moved between disks.", 0) \

2
src/Coordination/KeeperContext.cpp
View File

@ -160,7 +160,7 @@ void KeeperContext::initialize(const Poco::Util::AbstractConfiguration & config,
initializeDisks(config); initializeDisks(config);
#if USE_ROCKSDB #if USE_ROCKSDB
if (config.getBool("keeper_server.coordination_settings.use_rocksdb", true)) if (config.getBool("keeper_server.coordination_settings.experimental_use_rocksdb", false))
{ {
rocksdb_options = std::make_shared<rocksdb::Options>(getRocksDBOptionsFromConfig(config)); rocksdb_options = std::make_shared<rocksdb::Options>(getRocksDBOptionsFromConfig(config));
digest_enabled = false; /// TODO: support digest digest_enabled = false; /// TODO: support digest

2
src/Coordination/KeeperServer.cpp
View File

@ -134,7 +134,7 @@ KeeperServer::KeeperServer(
#if USE_ROCKSDB #if USE_ROCKSDB
const auto & coordination_settings = keeper_context->getCoordinationSettings(); const auto & coordination_settings = keeper_context->getCoordinationSettings();
if (coordination_settings->use_rocksdb) if (coordination_settings->experimental_use_rocksdb)
{ {
state_machine = nuraft::cs_new<KeeperStateMachine<KeeperRocksStorage>>( state_machine = nuraft::cs_new<KeeperStateMachine<KeeperRocksStorage>>(
responses_queue_, responses_queue_,

2
src/Coordination/tests/gtest_coordination.cpp
View File

@ -85,7 +85,7 @@ public:
Poco::Logger::root().setLevel("trace"); Poco::Logger::root().setLevel("trace");
auto settings = std::make_shared<DB::CoordinationSettings>(); auto settings = std::make_shared<DB::CoordinationSettings>();
settings->use_rocksdb = true; settings->experimental_use_rocksdb = true;
keeper_context = std::make_shared<DB::KeeperContext>(true, settings); keeper_context = std::make_shared<DB::KeeperContext>(true, settings);
keeper_context->setLocalLogsPreprocessed(); keeper_context->setLocalLogsPreprocessed();
keeper_context->setRocksDBOptions(); keeper_context->setRocksDBOptions();