diff --git a/be/src/exec/parquet_reader.cpp b/be/src/exec/parquet_reader.cpp index 6ed20206509289..0b38c160109299 100644 --- a/be/src/exec/parquet_reader.cpp +++ b/be/src/exec/parquet_reader.cpp @@ -68,7 +68,11 @@ Status ParquetReaderWrap::init_parquet_reader(const std::vector auto *schemaDescriptor = _file_metadata->schema(); for (int i = 0; i < _file_metadata->num_columns(); ++i) { // Get the Column Reader for the boolean column - _map_column.emplace(schemaDescriptor->Column(i)->name(), i); + if (schemaDescriptor->Column(i)->max_definition_level() > 1) { + _map_column.emplace(schemaDescriptor->Column(i)->path()->ToDotVector()[0], i); + } else { + _map_column.emplace(schemaDescriptor->Column(i)->name(), i); + } } _timezone = timezone;