summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/io/node_table_reader.cpp
diff options
context:
space:
mode:
authornadya73 <[email protected]>2024-04-18 12:01:09 +0300
committernadya73 <[email protected]>2024-04-18 12:11:25 +0300
commit044c22732c7e0fa5cbdd08543c7cd68a501170a6 (patch)
tree1d2f571d26bd697eb3e30102cd8d90ae5a28a201 /yt/cpp/mapreduce/io/node_table_reader.cpp
parent4d77c1fb4de7a121c720a5b403ba7aa516a32ce3 (diff)
[yt/cpp/mapreduce] YT-21405: Don't ignore backoff and pass actual exception in Retry()
Don't ignore backoff and pass actual exception in Retry() b821c02fd21c9f8115cd2a4896372a9fda69e5f6
Diffstat (limited to 'yt/cpp/mapreduce/io/node_table_reader.cpp')
-rw-r--r--yt/cpp/mapreduce/io/node_table_reader.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/yt/cpp/mapreduce/io/node_table_reader.cpp b/yt/cpp/mapreduce/io/node_table_reader.cpp
index ca529e14db9..bc3da75ee6b 100644
--- a/yt/cpp/mapreduce/io/node_table_reader.cpp
+++ b/yt/cpp/mapreduce/io/node_table_reader.cpp
@@ -354,7 +354,7 @@ void TNodeTableReader::OnStreamError(std::exception_ptr exception, TString error
{
YT_LOG_ERROR("Read error (RangeIndex: %v, RowIndex: %v, Error: %v)", RangeIndex_, RowIndex_, error);
Exception_ = exception;
- if (Input_.Retry(RangeIndex_, RowIndex_)) {
+ if (Input_.Retry(RangeIndex_, RowIndex_, exception)) {
if (RangeIndex_) {
RangeIndexShift_ += *RangeIndex_;
}