diff options
| author | Oleg Doronin <dorooleg@yandex.ru> | 2025-03-14 10:07:52 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-03-14 10:07:52 +0300 |
| commit | c39dd93abac1bfedd69222295717b2d519a8dd84 (patch) | |
| tree | 1b806d2e7364ad6b7a95c76fc0df2b21661ea343 | |
| parent | a520c9e013e4e878b493e5ddd954b90e221ced36 (diff) | |
| download | ydb-c39dd93abac1bfedd69222295717b2d519a8dd84.tar.gz | |
max timeout for FastRead (#15520)
| -rw-r--r-- | ydb/core/tx/columnshard/blob_cache.cpp | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/ydb/core/tx/columnshard/blob_cache.cpp b/ydb/core/tx/columnshard/blob_cache.cpp index 0287b876d5..f404a25536 100644 --- a/ydb/core/tx/columnshard/blob_cache.cpp +++ b/ydb/core/tx/columnshard/blob_cache.cpp @@ -92,7 +92,6 @@ private: static constexpr i64 MAX_IN_FLIGHT_BYTES = 250ll << 20; static constexpr i64 MAX_REQUEST_BYTES = 8ll << 20; static constexpr TDuration DEFAULT_READ_DEADLINE = TDuration::Seconds(30); - static constexpr TDuration FAST_READ_DEADLINE = TDuration::Seconds(10); TLRUCache<TBlobRange, TString> Cache; /// List of cached ranges by blob id. @@ -358,12 +357,11 @@ private: } static TInstant ReadDeadline(TReadItem::EReadVariant variant) { - if (variant == TReadItem::EReadVariant::FAST) { - return TAppData::TimeProvider->Now() + FAST_READ_DEADLINE; - } else if (variant == TReadItem::EReadVariant::DEFAULT) { + if (variant == TReadItem::EReadVariant::DEFAULT) { return TAppData::TimeProvider->Now() + DEFAULT_READ_DEADLINE; } - return TInstant::Max(); // EReadVariant::DEFAULT_NO_DEADLINE + // We want to wait for data anyway in this case. This behaviour is similar to datashard + return TInstant::Max(); // EReadVariant::DEFAULT_NO_DEADLINE || EReadVariant::FAST } void MakeReadRequests(const TActorContext& ctx) { |