aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorOleg Doronin <dorooleg@yandex.ru>2025-03-14 10:07:52 +0300
committerGitHub <noreply@github.com>2025-03-14 10:07:52 +0300
commitc39dd93abac1bfedd69222295717b2d519a8dd84 (patch)
tree1b806d2e7364ad6b7a95c76fc0df2b21661ea343
parenta520c9e013e4e878b493e5ddd954b90e221ced36 (diff)
downloadydb-c39dd93abac1bfedd69222295717b2d519a8dd84.tar.gz
max timeout for FastRead (#15520)
-rw-r--r--ydb/core/tx/columnshard/blob_cache.cpp8
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) {