From 9402456f5b86cd9067ea40afe1d7ac19beef0432 Mon Sep 17 00:00:00 2001
From: HangyuanLiu <460660596@qq.com>
Date: Wed, 7 Aug 2019 15:08:22 +0800
Subject: [PATCH] Fix parquet directory have empty file (#1593)

---
 be/src/exec/parquet_reader.cpp  | 3 +++
 be/src/exec/parquet_scanner.cpp | 7 ++++++-
 2 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/be/src/exec/parquet_reader.cpp b/be/src/exec/parquet_reader.cpp
index a60295b0fa..502fa0ef51 100644
--- a/be/src/exec/parquet_reader.cpp
+++ b/be/src/exec/parquet_reader.cpp
@@ -55,6 +55,9 @@ Status ParquetReaderWrap::init_parquet_reader(const std::vector<SlotDescriptor*>
         _file_metadata = _reader->parquet_reader()->metadata();
         // initial members
         _total_groups = _file_metadata->num_row_groups();
+        if (_total_groups == 0) {
+            return Status::EndOfFile("Empty Parquet File");
+        }
         _rows_of_group = _file_metadata->RowGroup(0)->num_rows();
 
         // map
diff --git a/be/src/exec/parquet_scanner.cpp b/be/src/exec/parquet_scanner.cpp
index c69d19940d..2ce43a1219 100644
--- a/be/src/exec/parquet_scanner.cpp
+++ b/be/src/exec/parquet_scanner.cpp
@@ -142,7 +142,12 @@ Status ParquetScanner::open_next_reader() {
             continue;
         }
         _cur_file_reader = new ParquetReaderWrap(file_reader.release());
-        return _cur_file_reader->init_parquet_reader(_src_slot_descs);
+        Status status = _cur_file_reader->init_parquet_reader(_src_slot_descs);
+        if (status.is_end_of_file()) {
+            continue;
+        } else {
+            return status;
+        }
     }
 }