Signed-off-by: luofucong <luofc@foxmail.com>
This commit is contained in:
luofucong
2026-04-03 18:38:19 +08:00
parent 668934eb09
commit 389300bf7d
2 changed files with 4 additions and 0 deletions

View File

@@ -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::<i32>();
let item_aligned =
match (expect_item.data_type(), array_item.data_type()) {

View File

@@ -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);