diff options
Diffstat (limited to 'yt/cpp/mapreduce/io/lenval_table_reader.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/io/lenval_table_reader.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/io/lenval_table_reader.cpp b/yt/cpp/mapreduce/io/lenval_table_reader.cpp index d7a1c9754ee..676400b1df3 100644 --- a/yt/cpp/mapreduce/io/lenval_table_reader.cpp +++ b/yt/cpp/mapreduce/io/lenval_table_reader.cpp @@ -2,6 +2,7 @@ #include <yt/cpp/mapreduce/common/helpers.h> +#include <yt/cpp/mapreduce/interface/errors.h> #include <yt/cpp/mapreduce/interface/logging/yt_log.h> #include <util/string/printf.h> @@ -30,6 +31,9 @@ TLenvalTableReader::~TLenvalTableReader() void TLenvalTableReader::CheckValidity() const { + if (Input_.IsAborted()) { + ythrow TInputStreamAbortedError() << "Stream was aborted"; + } if (!IsValid()) { ythrow yexception() << "Iterator is not valid"; } |