From d9661b4b1e0784de416eed54de834ac02f1d2793 Mon Sep 17 00:00:00 2001 From: luofucong Date: Mon, 8 Jun 2026 20:07:13 +0800 Subject: [PATCH] debug Signed-off-by: luofucong --- src/datatypes/src/vectors/json/array.rs | 3 +-- src/mito2/src/sst/parquet/reader.rs | 7 ++++--- src/mito2/src/sst/parquet/reader/stream.rs | 2 ++ 3 files changed, 7 insertions(+), 5 deletions(-) diff --git a/src/datatypes/src/vectors/json/array.rs b/src/datatypes/src/vectors/json/array.rs index b3bd24cd98..37174adbda 100644 --- a/src/datatypes/src/vectors/json/array.rs +++ b/src/datatypes/src/vectors/json/array.rs @@ -25,7 +25,6 @@ use arrow_array::cast::AsArray; use arrow_array::types::{Float64Type, Int64Type, UInt64Type}; use arrow_array::{Array, ArrayRef, GenericListArray, ListArray, StructArray, new_null_array}; use arrow_schema::{DataType, FieldRef}; -use common_telemetry::debug; use serde_json::Value; use snafu::{OptionExt, ResultExt}; @@ -109,7 +108,7 @@ impl JsonArray<'_> { return Ok(self.inner.clone()); } - debug!( + common_telemetry::trace!( "Try aligning JSON array {} to data type {}", self.inner.data_type(), expect diff --git a/src/mito2/src/sst/parquet/reader.rs b/src/mito2/src/sst/parquet/reader.rs index 366d643a55..34c112077a 100644 --- a/src/mito2/src/sst/parquet/reader.rs +++ b/src/mito2/src/sst/parquet/reader.rs @@ -1843,12 +1843,13 @@ impl RowGroupReaderBuilder { return Ok(stream); } - Ok(NestedSchemaAligner::new( + let stream = NestedSchemaAligner::new( stream, self.projection.projected_root_presence.clone(), self.output_schema.clone(), - )? - .boxed()) + )?; + common_telemetry::debug!("created: {:?}", stream); + Ok(stream.boxed()) } /// Builds a parquet record batch stream with a custom projection mask. diff --git a/src/mito2/src/sst/parquet/reader/stream.rs b/src/mito2/src/sst/parquet/reader/stream.rs index 1a17d6be64..db37081e5d 100644 --- a/src/mito2/src/sst/parquet/reader/stream.rs +++ b/src/mito2/src/sst/parquet/reader/stream.rs @@ -44,7 +44,9 @@ use crate::error::{CastColumnSnafu, NewRecordBatchSnafu, Result, UnexpectedSnafu /// inserting root-level null arrays. /// - Nested struct alignment aligns struct arrays to the expected nested field /// layout. +#[derive(derive_more::Debug)] pub struct NestedSchemaAligner { + #[debug(skip)] inner: S, /// Output schema expected by the upper reader. output_schema: SchemaRef,