diff options
| author | o-gulyaev <[email protected]> | 2026-03-24 13:16:49 +0300 |
|---|---|---|
| committer | o-gulyaev <[email protected]> | 2026-03-24 18:19:22 +0300 |
| commit | 1ae216caf1a33b4a8e8abcdb551ffd15af26ebb5 (patch) | |
| tree | 4ddcd59bb8e0739e196662f1248f77ee54c9f29d /yt/cpp/mapreduce/interface/config.cpp | |
| parent | eb43dfebcb9d7f2bfd50d13d5091fde0705416b6 (diff) | |
make FileCacheReplicationFactor dynamic in cpp sdk
Мы делаем минимальную версию кластера с replication factor 1, чтобы внешние юзеры могли развернуть кластер для тестирования функциональности на минимуме ресурсов на одной машике с одной датанодой. Необходимость этих фиксов всплыла, когда я заметил, что YQL запрос при подготовке операции грузит в Кипарис различные файлы – .so-шки с библиотеками, mrjob и прочее. Все это грузилось с дефолтными константами rf, сделал так, чтобы их можно было переопределить.
* Changelog entry
Type: feature
Component: cpp-sdk
make option `file_cache_replication_factor` dynamic
commit_hash:900ea0d6483926e7a444c5b593cf661544744590
Diffstat (limited to 'yt/cpp/mapreduce/interface/config.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/interface/config.cpp | 2 |
1 files changed, 0 insertions, 2 deletions
diff --git a/yt/cpp/mapreduce/interface/config.cpp b/yt/cpp/mapreduce/interface/config.cpp index 494b6517ccf..9379ab57473 100644 --- a/yt/cpp/mapreduce/interface/config.cpp +++ b/yt/cpp/mapreduce/interface/config.cpp @@ -449,7 +449,6 @@ void Serialize(const TConfig& config, NYson::IYsonConsumer* consumer) .Item("node_reader_format").Value(::ToString(config.NodeReaderFormat)) .Item("protobuf_format_with_descriptors").Value(config.ProtobufFormatWithDescriptors) .Item("connection_pool_size").Value(config.ConnectionPoolSize) - .Item("file_cache_replication_factor").Value(config.FileCacheReplicationFactor) .Item("cache_lock_timeout_per_gb").Value(config.CacheLockTimeoutPerGb.ToString()) .Item("cache_upload_deduplication_mode") .Value(TEnumTraits<EUploadDeduplicationMode>::ToString(config.CacheUploadDeduplicationMode)) @@ -527,7 +526,6 @@ void Deserialize(TConfig& config, const TNode& node) DESERIALIZE_ITEM("node_reader_format", config.NodeReaderFormat); DESERIALIZE_ITEM("protobuf_format_with_descriptors", config.ProtobufFormatWithDescriptors); DESERIALIZE_ITEM("connection_pool_size", config.ConnectionPoolSize); - DESERIALIZE_ITEM("file_cache_replication_factor", config.FileCacheReplicationFactor); DESERIALIZE_ITEM("cache_lock_timeout_per_gb", config.CacheLockTimeoutPerGb); DESERIALIZE_ITEM("cache_upload_deduplication_mode", config.CacheUploadDeduplicationMode); DESERIALIZE_ITEM("cache_upload_deduplication_threshold", config.CacheUploadDeduplicationThreshold); |