diff --git a/src/datatypes/src/vectors/json/array.rs b/src/datatypes/src/vectors/json/array.rs index ee60c47d3f..862abf9658 100644 --- a/src/datatypes/src/vectors/json/array.rs +++ b/src/datatypes/src/vectors/json/array.rs @@ -77,6 +77,8 @@ impl JsonArray<'_> { JsonArray::from(&array_columns[j]).try_align(expect_type)? } (DataType::List(expect_item), DataType::List(array_item)) => { + common_telemetry::info!("1. expect_item: {}", expect_item.data_type()); + common_telemetry::info!("2. array_item: {}", array_item.data_type()); let list_array = array_columns[j].as_list::(); let item_aligned = match (expect_item.data_type(), array_item.data_type()) { diff --git a/src/mito2/src/memtable.rs b/src/mito2/src/memtable.rs index 68f16fe204..efc14541b5 100644 --- a/src/mito2/src/memtable.rs +++ b/src/mito2/src/memtable.rs @@ -273,8 +273,10 @@ pub(crate) fn merge_json_extension_fields(base: &SchemaRef, others: &[SchemaRef] if let Some(merged) = merged && field.data_type() != merged.as_ref() { + common_telemetry::info!("before merged: {}", field.data_type()); let merged = json_type::merge_as_json_type(field.data_type(), merged.as_ref()).into_owned(); + common_telemetry::info!("after merged: {}", merged); let mut new = field.as_ref().clone(); new.set_data_type(merged);