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 1c441a9 commit 718355dCopy full SHA for 718355d
ydb/library/yql/providers/yt/codec/yt_codec_io.cpp
@@ -1491,12 +1491,7 @@ class TArrowDecoder : public TMkqlReaderImpl::TDecoder {
1491
1492
bool ReadNext() {
1493
if (!StreamReader_) {
1494
- // 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);
+ StreamReader_ = ARROW_RESULT(arrow::ipc::RecordBatchStreamReader::Open(InputStream_.get()));
1500
1501
auto oldTableIndex = TableIndex_;
1502
if (!IgnoreStreamTableIndex) {
0 commit comments