summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/io/skiff_table_reader.cpp
diff options
context:
space:
mode:
authorSavchenko Nadezhda <[email protected]>2024-04-18 10:57:19 +0200
committerGitHub <[email protected]>2024-04-18 11:57:19 +0300
commitb65fd71bd2a02aca196f47954fa03ac9aa94b8a0 (patch)
treebc8f88414f9a6648318388dca5b6a28ec36f8658 /yt/cpp/mapreduce/io/skiff_table_reader.cpp
parenta1bcf08e286611efa4a394a53c894ebb954acd93 (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.cpp6
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_);