aboutsummaryrefslogtreecommitdiffstats
path: root/yt
diff options
context:
space:
mode:
authordon-dron <don-dron@yandex-team.com>2024-05-22 20:16:51 +0300
committerdon-dron <don-dron@yandex-team.com>2024-05-22 20:25:39 +0300
commite87910961a67ae6691b2768e5b82d9e70c6ba0cb (patch)
treef51e7ce211bccf7543d4e82c39dcff37a6112677 /yt
parent3f4e4e3bc2b2e50fdb89397aab22f217bf4c6af5 (diff)
downloadydb-e87910961a67ae6691b2768e5b82d9e70c6ba0cb.tar.gz
YT-21692: Decrease probing requests in replication reader
f0710477546e5c8f2c1675d5065bf403e0bc6e86
Diffstat (limited to 'yt')
-rw-r--r--yt/yt/client/chunk_client/config.cpp2
-rw-r--r--yt/yt/client/chunk_client/config.h3
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);