diff options
| author | don-dron <don-dron@yandex-team.com> | 2024-05-22 20:16:51 +0300 |
|---|---|---|
| committer | don-dron <don-dron@yandex-team.com> | 2024-05-22 20:25:39 +0300 |
| commit | e87910961a67ae6691b2768e5b82d9e70c6ba0cb (patch) | |
| tree | f51e7ce211bccf7543d4e82c39dcff37a6112677 | |
| parent | 3f4e4e3bc2b2e50fdb89397aab22f217bf4c6af5 (diff) | |
| download | ydb-e87910961a67ae6691b2768e5b82d9e70c6ba0cb.tar.gz | |
YT-21692: Decrease probing requests in replication reader
f0710477546e5c8f2c1675d5065bf403e0bc6e86
| -rw-r--r-- | yt/yt/client/chunk_client/config.cpp | 2 | ||||
| -rw-r--r-- | yt/yt/client/chunk_client/config.h | 3 |
2 files changed, 5 insertions, 0 deletions
diff --git a/yt/yt/client/chunk_client/config.cpp b/yt/yt/client/chunk_client/config.cpp index dbf22f06d3..c7431e126b 100644 --- a/yt/yt/client/chunk_client/config.cpp +++ b/yt/yt/client/chunk_client/config.cpp @@ -168,6 +168,8 @@ void TReplicationReaderConfig::Register(TRegistrar registrar) .Default(false); registrar.Parameter("chunk_meta_cache_failure_probability", &TThis::ChunkMetaCacheFailureProbability) .Default(); + registrar.Parameter("use_chunk_prober", &TThis::UseChunkProber) + .Default(false); registrar.Postprocessor([] (TThis* config) { // Seems unreasonable to make backoff greater than half of total session timeout. diff --git a/yt/yt/client/chunk_client/config.h b/yt/yt/client/chunk_client/config.h index b5efb3ed2c..9683176ee8 100644 --- a/yt/yt/client/chunk_client/config.h +++ b/yt/yt/client/chunk_client/config.h @@ -243,6 +243,9 @@ public: //! Unless null, reader will simulate failure of accessing chunk meta cache with such probability. std::optional<double> ChunkMetaCacheFailureProbability; + //! Use chunk prober to reduce the number of probing requests. + bool UseChunkProber; + REGISTER_YSON_STRUCT(TReplicationReaderConfig); static void Register(TRegistrar registrar); |