From 044c22732c7e0fa5cbdd08543c7cd68a501170a6 Mon Sep 17 00:00:00 2001 From: nadya73 Date: Thu, 18 Apr 2024 12:01:09 +0300 Subject: [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 --- yt/cpp/mapreduce/io/node_table_reader.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'yt/cpp/mapreduce/io/node_table_reader.cpp') 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_; } -- cgit v1.3