From a044766d5899aa2b43b33d9a6e40ce53516f4d37 Mon Sep 17 00:00:00 2001 From: FawnD2 Date: Mon, 4 May 2020 16:26:20 +0300 Subject: [PATCH] Remove check --- src/Processors/Formats/Impl/ParquetBlockInputFormat.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/Processors/Formats/Impl/ParquetBlockInputFormat.cpp b/src/Processors/Formats/Impl/ParquetBlockInputFormat.cpp index 1f3df680504..c067809fe47 100644 --- a/src/Processors/Formats/Impl/ParquetBlockInputFormat.cpp +++ b/src/Processors/Formats/Impl/ParquetBlockInputFormat.cpp @@ -41,7 +41,7 @@ Chunk ParquetBlockInputFormat::generate() Chunk res; const Block & header = getPort().getHeader(); - if (in.eof() || row_group_current >= row_group_total) + if (row_group_current >= row_group_total) return res; std::shared_ptr table;