diff options
| author | Savchenko Nadezhda <[email protected]> | 2024-04-18 10:57:19 +0200 |
|---|---|---|
| committer | GitHub <[email protected]> | 2024-04-18 11:57:19 +0300 |
| commit | b65fd71bd2a02aca196f47954fa03ac9aa94b8a0 (patch) | |
| tree | bc8f88414f9a6648318388dca5b6a28ec36f8658 /yt/cpp/mapreduce/io/skiff_table_reader.cpp | |
| parent | a1bcf08e286611efa4a394a53c894ebb954acd93 (diff) | |
Don't ignore backoff and pass actual exception in Retry() (#3664)
Diffstat (limited to 'yt/cpp/mapreduce/io/skiff_table_reader.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/io/skiff_table_reader.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/yt/cpp/mapreduce/io/skiff_table_reader.cpp b/yt/cpp/mapreduce/io/skiff_table_reader.cpp index 3f6440a8bb1..446c5291692 100644 --- a/yt/cpp/mapreduce/io/skiff_table_reader.cpp +++ b/yt/cpp/mapreduce/io/skiff_table_reader.cpp @@ -98,9 +98,9 @@ void TSkiffTableReader::Next() try { ReadRow(); break; - } catch (const std::exception& exception) { - YT_LOG_ERROR("Read error: %v", exception.what()); - if (!Input_.Retry(RangeIndex_, RowIndex_)) { + } catch (const std::exception& ex) { + YT_LOG_ERROR("Read error: %v", ex.what()); + if (!Input_.Retry(RangeIndex_, RowIndex_, std::make_exception_ptr(ex))) { throw; } BufferedInput_ = TBufferedInput(&Input_); |
