From 6d6d04903f3e75e294da5224e8df47e1cbfbb5f2 Mon Sep 17 00:00:00 2001 From: FawnD2 Date: Mon, 4 May 2020 16:33:20 +0300 Subject: [PATCH] Remove check --- src/Processors/Formats/Impl/ArrowBlockInputFormat.cpp | 3 --- 1 file changed, 3 deletions(-) diff --git a/src/Processors/Formats/Impl/ArrowBlockInputFormat.cpp b/src/Processors/Formats/Impl/ArrowBlockInputFormat.cpp index 6be6b320286..624d193a8f4 100644 --- a/src/Processors/Formats/Impl/ArrowBlockInputFormat.cpp +++ b/src/Processors/Formats/Impl/ArrowBlockInputFormat.cpp @@ -31,9 +31,6 @@ Chunk ArrowBlockInputFormat::generate() Chunk res; const Block & header = getPort().getHeader(); - if (in.eof()) - return res; - std::vector> single_batch(1); arrow::Status read_status = reader->ReadNext(&single_batch[0]); if (!read_status.ok())