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_;
         }