diff --git a/be/src/exec/hdfs_scanner.cpp b/be/src/exec/hdfs_scanner.cpp index 695780c21245c..a6a772011668b 100644 --- a/be/src/exec/hdfs_scanner.cpp +++ b/be/src/exec/hdfs_scanner.cpp @@ -187,8 +187,8 @@ Status HdfsScanner::_build_scanner_context() { opts.pred_tree_params = _runtime_state->fragment_ctx()->pred_tree_params(); ctx.conjuncts_manager = std::make_unique(std::move(opts)); RETURN_IF_ERROR(ctx.conjuncts_manager->parse_conjuncts()); - auto* predicate_parser = opts.obj_pool->add( - new ConnectorPredicateParser(&_scanner_params.tuple_desc->decoded_slots())); + auto* predicate_parser = + opts.obj_pool->add(new ConnectorPredicateParser(&_scanner_params.tuple_desc->decoded_slots())); ASSIGN_OR_RETURN(ctx.predicate_tree, ctx.conjuncts_manager->get_predicate_tree(predicate_parser, ctx.predicate_free_pool)); ctx.rf_scan_range_pruner = opts.obj_pool->add( diff --git a/be/src/formats/parquet/column_reader_factory.h b/be/src/formats/parquet/column_reader_factory.h index c526d5ffcf9df..9bc15001cfa85 100644 --- a/be/src/formats/parquet/column_reader_factory.h +++ b/be/src/formats/parquet/column_reader_factory.h @@ -28,8 +28,8 @@ class ColumnReaderFactory { const TypeDescriptor& col_type, const TIcebergSchemaField* iceberg_schema_field); - static StatusOr create(ColumnReaderPtr raw_reader, const GlobalDictMap* dict, - const SlotId slot_id, int64_t num_rows); + static StatusOr create(ColumnReaderPtr raw_reader, const GlobalDictMap* dict, const SlotId slot_id, + int64_t num_rows); private: // for struct type without schema change diff --git a/be/src/formats/parquet/complex_column_reader.cpp b/be/src/formats/parquet/complex_column_reader.cpp index 6fdffce446019..aa1b4288524a3 100644 --- a/be/src/formats/parquet/complex_column_reader.cpp +++ b/be/src/formats/parquet/complex_column_reader.cpp @@ -128,8 +128,8 @@ Status ListColumnReader::fill_dst_column(ColumnPtr& dst, ColumnPtr& src) { array_column_dst = down_cast(dst.get()); } array_column_dst->offsets_column()->swap_column(*(array_column_src->offsets_column())); - RETURN_IF_ERROR(_element_reader->fill_dst_column( - array_column_dst->elements_column(), array_column_src->elements_column())); + RETURN_IF_ERROR( + _element_reader->fill_dst_column(array_column_dst->elements_column(), array_column_src->elements_column())); return Status::OK(); }