[Enhancement] Support json logical type in parquet files() (backport #49385)

be/src/exec/parquet_schema_builder.cpp

@@ -88,6 +88,8 @@ static Status get_parquet_type_from_primitive(const ::parquet::schema::NodePtr&
             auto decimal_logical_type = std::dynamic_pointer_cast<const parquet::DecimalLogicalType>(logical_type);
             *type_desc = TypeDescriptor::create_decimalv3_type(TYPE_DECIMAL128, decimal_logical_type->precision(),
                                                                decimal_logical_type->scale());
+        } else if (logical_type->is_JSON()) {
+            *type_desc = TypeDescriptor::create_json_type();
         } else {
             *type_desc = TypeDescriptor::create_varbinary_type(TypeDescriptor::MAX_VARCHAR_LENGTH);
         }

test/sql/test_files/R/json_parquet

@@ -0,0 +1,42 @@
+-- name: test_json_parquet
+
+create database db_${uuid0};
+use db_${uuid0};
+
+shell: ossutil64 mkdir oss://${oss_bucket}/test_files/parquet_format/${uuid0} >/dev/null || echo "exit 0" >/dev/null
+
+shell: ossutil64 cp --force ./sql/test_files/parquet_format/json.parquet oss://${oss_bucket}/test_files/parquet_format/${uuid0}/ | grep -Pv "(average|elapsed)"
+-- result:
+0
+
+Succeed: Total num: 1, size: 911. OK num: 1(upload 1 files).
+-- !result
+
+select * from files('path' = 'oss://${oss_bucket}/test_files/parquet_format/${uuid0}/*', 'format' = 'parquet');
+-- result:
+1	["a", "b"]
+2	["c", "d"]
+-- !result
+
+create table t1 as select * from files('path' = 'oss://${oss_bucket}/test_files/parquet_format/${uuid0}/*', 'format' = 'parquet');
+
+desc t1;
+-- result:
+id	bigint	YES	true	None	
+json_data	json	YES	false	None	
+-- !result
+
+create table t2 (id bigint, array_col array<varchar(100)>);
+
+insert into t2 select * from files('path' = 'oss://${oss_bucket}/test_files/parquet_format/${uuid0}/*', 'format' = 'parquet');
+-- result:
+-- !result
+
+select * from t2;
+-- result:
+1	["a","b"]
+2	["c","d"]
+-- !result
+
+
+shell: ossutil64 rm -rf oss://${oss_bucket}/test_files/parquet_format/${uuid0}/ > /dev/null

test/sql/test_files/T/json_parquet

@@ -0,0 +1,18 @@
+-- name: test_json_parquet
+
+create database db_${uuid0};
+use db_${uuid0};
+
+shell: ossutil64 mkdir oss://${oss_bucket}/test_files/parquet_format/${uuid0} >/dev/null || echo "exit 0" >/dev/null
+shell: ossutil64 cp --force ./sql/test_files/parquet_format/json.parquet oss://${oss_bucket}/test_files/parquet_format/${uuid0}/ | grep -Pv "(average|elapsed)"
+
+select * from files('path' = 'oss://${oss_bucket}/test_files/parquet_format/${uuid0}/*', 'format' = 'parquet');
+
+create table t1 as select * from files('path' = 'oss://${oss_bucket}/test_files/parquet_format/${uuid0}/*', 'format' = 'parquet');
+desc t1;
+
+create table t2 (id bigint, array_col array<varchar(100)>);
+insert into t2 select * from files('path' = 'oss://${oss_bucket}/test_files/parquet_format/${uuid0}/*', 'format' = 'parquet');
+select * from t2;
+
+shell: ossutil64 rm -rf oss://${oss_bucket}/test_files/parquet_format/${uuid0}/ > /dev/null