aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authormrlolthe1st <mrlolthe1st@yandex-team.com>2025-02-24 17:28:45 +0300
committermrlolthe1st <mrlolthe1st@yandex-team.com>2025-02-24 17:47:20 +0300
commitc6150180525bd679a4696b128fc525eef6b3cd45 (patch)
treeaf2315253d1be620fd62a638347d53f6abc63a08
parent625b0b4c1f0275ee928b9a6ded1a491569c51bf9 (diff)
downloadydb-c6150180525bd679a4696b128fc525eef6b3cd45.tar.gz
YQL-19625: Fallback on memory limit
commit_hash:6a6eefb18d35d0e1faa59eb6b72a25dbe416bb16
-rw-r--r--yt/yql/providers/yt/codec/yt_codec_io.cpp3
1 files changed, 3 insertions, 0 deletions
diff --git a/yt/yql/providers/yt/codec/yt_codec_io.cpp b/yt/yql/providers/yt/codec/yt_codec_io.cpp
index 459602d9cf..0bc03184aa 100644
--- a/yt/yql/providers/yt/codec/yt_codec_io.cpp
+++ b/yt/yql/providers/yt/codec/yt_codec_io.cpp
@@ -1752,6 +1752,9 @@ void TMkqlReaderImpl::Next() {
} catch (const TYqlPanic& e) {
ythrow TYqlPanic() << "Failed to read row, table index: " << Decoder_->TableIndex_ << ", row index: " <<
(Decoder_->RowIndex_.Defined() ? ToString(*Decoder_->RowIndex_) : "?") << "\n" << e.what();
+ } catch (const TMemoryLimitExceededException&) {
+ ythrow TYqlPanic() << "Failed to read row, table index: " << Decoder_->TableIndex_ << ", row index: " <<
+ (Decoder_->RowIndex_.Defined() ? ToString(*Decoder_->RowIndex_) : "?") << ". Memory limit exceeded in MKQL runtime";
} catch (const TTimeoutException&) {
throw;
} catch (const yexception& e) {