We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f282430 commit f00baa4Copy full SHA for f00baa4
ydb/library/yql/providers/yt/codec/yt_codec_io.cpp
@@ -1491,7 +1491,12 @@ class TArrowDecoder : public TMkqlReaderImpl::TDecoder {
1491
1492
bool ReadNext() {
1493
if (!StreamReader_) {
1494
- StreamReader_ = ARROW_RESULT(arrow::ipc::RecordBatchStreamReader::Open(InputStream_.get()));
+ // Deal with empty input
1495
+ auto streamReaderResult = arrow::ipc::RecordBatchStreamReader::Open(InputStream_.get());
1496
+ if (!streamReaderResult.ok() && InputStream_->EOSReached()) {
1497
+ return false;
1498
+ }
1499
+ StreamReader_ = ARROW_RESULT(streamReaderResult);
1500
1501
auto oldTableIndex = TableIndex_;
1502
if (!IgnoreStreamTableIndex) {
0 commit comments