This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch auto-pick-48673-branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
omit 27840f02d71 [enhance](mtmv)Only restrict MTMV to not allow concurrent
insert overwrite execution (#48673)
add 8199febcdb0 [Test][Fix](parquet-reader) Add parquet decoder unit tests
and fix bugs by these tests. (#49922)
add a512edc7e2c [fix](multi-catalog) Fix multi-thread issue in
hive/iceberg writer commit meta-info to fe. (#49920)
add 826cbfdb630 [deps](jindofs) add jindofs for 2.1
(#49259)(#49371)(#49374)(#49502)(#49503)(#49886)(#49903) (#49908)
add 4ae9451b637 branch-2.1: [opt](connection) add connection num in error
msg (#49471) (#49910)
add bfe74695603 branch-2.1: [fix](oss) the write to hive table on oss-hdfs
may fail (#49754) (#49911)
add c83c2e18bc0 [fix](planner) fix fallback to legacy planner compute
wrong result (#49913)
add e4d0c672a30 branch-2.1: [fix](Nereids) cse extract wrong expression
from lambda expressions (#49166) (#49942)
add 78b8f318957 branch-2.1 [Fix](Catalog) Close system resources when
dropping catalog ( #49621) (#49935)
add 308ede0657e branch-2.1-pick: [Fix](full compaction) Fix problems for
full compaction #49825 (#49919)
add 530bad3d14b Set isQuery audit log correctly when fallback to old
planner. (#49959)
add 40a62c3b82c branch-2.1: [feat](dialect) add starrocks dialect #49951
(#49974)
add d8a274251eb branch-2.1: [feature](function) support utf8 input in
initcap #49846 (#49977)
add e70a3ab8b16 branch-2.1: [fix] (streamload) fixed the issue of data
loss due to concurrency wh… #48948 (#49937)
add ba1ad12a210 branch-2.1: [Fix](Serde) Support hive compatible output
format #49036 (#49831)
add 9960b0960e7 branch-2.1: [bug](auto partition) Fix be crash with single
replica insert (#48929)
add b9d447741e8 Revert "branch-2.1: [Fix](Serde) Support hive compatible
output format #49036" (#49986)
add 6e448d3a562 [feat](test)add some be ut for orc/parquet reader
(#49418) (#49948)
add 7ba2f870879 branch-2.1: [fix](binlog) Replaced partition should be
record to Dropped Resources #48686 (#49789)
add d87409c5cad [fix](inverted index) Downgrade ICU version to support
lower OS versions #47664 (#50005)
add 06ab763efbe branch-2.1: [fix](parquet)fix when
hive_parquet_use_column_names=false && read partition tb cause be core. #49966
(#50008)
add bbdb057e2c9 branch-2.1: [fix](nereids) EliminateGroupByConstant should
replace agg's group by after removing constant group by keys #49473 (#50044)
add fe634555bd2 [fix](variant)fix core in column_object when sort from
empty block (#50035)
add aa4b54952cd branch-2.1: [enhancement]Optimize GeoFunctions for const
columns #34396 (#50067)
add da8722f7035 branch-2.1: chore: disable download md5sum check by
default #50012 (#50047)
add afaab7ff98c branch-2.1-pick: [Opt](log) Add and fix logs for delete
bitmaps (#50060)
add c38ca0cd461 branch-2.1: [test]add test for restore schema not consist
#49849 (#50070)
add 2ef136cad61 [fix](variant) building index on the variant column is
prohibited (#49159) (#50028)
add 2aa9cb22768 branch-2.1: [fix](lzo) fix lzo decompression failed #49538
(#49634)
add ea29bc523e7 branch-2.1: [Enhancement](GEO) Support Multipolygon and
some spatial functions (#50073)
add 41b5866c3e4 [fix](regression) fix the failed of
cold_heat_separation_p2 (#49625) (#50090)
add c3a201dcbf2 branch-2.1: [fix](agg) prevent core dump in
ColumnArray::size_at when handling type mismatch in
streaming_agg_serialize_to_column #50001 (#50095)
add 77ea907b548 branch-2.1: [Bug](materialized-view) Fixed the problem of
using drop table force and create mv stmt at the… #41580 (#50133)
add 4146cbbbbbd branch-2.1-pick: [Opt](mow) Forbid time_series compaction
policy on unique table (#49905) (#50132)
add 89862856fe5 print error info when parse_conf_cache_paths failed, so
that user know how to correct it (#50131)
add 64815c6403a branch-2.1: [fix](dialect)fix starrocks dialect #50099
(#50165)
add 94f5fd77285 [chore] Updated submodule orc to orc-for-doris-21 branch.
(#50189)
add 967d0a59b9a branch-2.1: [fix](load) reset routine load task EOF sign
correctly #50048 (#50179)
add 048537cd036 branch-2.1:[fix](nereids)Use utf-8 when convert string
like literal to double. (#50085) (#50155)
add 481fca67661 [revert](statistics)Still use sample analyze sql when
sample full table. (#50199)
add 01b5cc4f1f4 [opt](mtmv) Doesn't throw npe when not set distribution
info which should be random (#49402)
add d575a0921aa [fix](hive) Fix hive metastore client socket timeout
(#50192)
add 188cbabb586 [enhance](auth)Remove restrictions on user creation and
other operations when enabling ranger/LDAP (#50137)
add 1c90fc6c029 branch-2.1: [fix](connect) fix wrong format causing
connection fail #50214 (#50217)
add 3088aff43c4 branch-2.1: [Fix](case) Fix case that use time series
compaction on unique table (#50194) (#50228)
add 9123d73ed8c Branch-2.1 Cherry-pick [Fix](Variant) fix variant cast to
jsonb into wrong NULL values (#50235)
add b9bb9e1611c branch-2.1: [fix](Export) fix the lock leak issue of
Export #50088 (#50219)
add 34cb4f05e83 [branch-2.1]fix task queue core (#50236)
add 1efe62c7ba7 branch-2.1: [opt](hive) add option to get schema from
table object #50038 (#50269)
add a193f16a5aa branch-2.1:[fix](auditlog)Set sqlHash in
executeInternalQuery (#49984) (#50271)
add af0bca698ad [Branch-2.1](Parquet) add a memory tracker to parquet meta
(#50130)
add 98f5d95fba8 branch-2.1: [feat](function) SUBSTRING_INDEX function
delimiter supports dynamic #50149 (#50303)
add b8660682176 [chore] Update submodule orc to orc-for-doris-21 branch in
build.sh. (#50304)
add b0c8cb0818d branch-2.1: [Bug](function) fix Could not find function
explode_json_array_json_outer #50164 (#50227)
add e5a9c2552d7 [chore] Add Clang 18/19 Support #47438 (#50300)
add cf72fa82e2d [Improve](explode) explode function support multi param
(#50310)
add bc68a8da070 branch-2.1: remove visible rowset from memory during
deletion transaction (#50329)
add 91eed373beb branch-2.1: [fix](array_map) fix array_map functions avoid
core #50201 (#50331)
add dd43f135495 branch-2.1:[fix](ut)Fix StmtExecutorTest (#50322) (#50362)
add 90e22197ff0 [fix](json-functions)fix json-replace/insert/set/array
behavior with complex type #50308 (#50309)
add 3792710b750 [enhance](mtmv)Only restrict MTMV to not allow concurrent
insert overwrite execution (#48673)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (27840f02d71)
\
N -- N -- N refs/heads/auto-pick-48673-branch-2.1 (3792710b750)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.gitmodules | 2 +-
be/CMakeLists.txt | 5 +-
be/src/agent/be_exec_version_manager.h | 2 +-
be/src/common/config.cpp | 2 +-
be/src/exec/lzo_decompressor.cpp | 18 +-
be/src/geo/geo_common.h | 7 +-
be/src/geo/geo_types.cpp | 988 ++++++++++++++
be/src/geo/geo_types.h | 59 +
be/src/geo/wkt_parse_type.h | 2 +
be/src/geo/wkt_yacc.y | 37 +-
be/src/olap/data_dir.cpp | 39 +-
be/src/olap/full_compaction.cpp | 98 +-
be/src/olap/full_compaction.h | 5 +-
be/src/olap/rowset/beta_rowset_writer.cpp | 5 +-
be/src/olap/rowset_builder.cpp | 10 +-
be/src/olap/tablet.cpp | 8 +-
be/src/olap/tablet_meta.cpp | 11 +
be/src/olap/tablet_meta.h | 2 +
be/src/olap/txn_manager.cpp | 5 +-
be/src/pipeline/exec/exchange_sink_buffer.cpp | 2 +-
be/src/pipeline/exec/exchange_sink_buffer.h | 2 +-
be/src/pipeline/exec/hashjoin_probe_operator.cpp | 4 +-
be/src/pipeline/exec/table_function_operator.cpp | 6 +-
be/src/pipeline/task_queue.cpp | 34 +-
be/src/pipeline/task_queue.h | 9 +-
be/src/runtime/exec_env.h | 4 +
be/src/runtime/exec_env_init.cpp | 4 +-
be/src/runtime/fragment_mgr.cpp | 28 +-
be/src/runtime/query_context.cpp | 5 +-
be/src/runtime/runtime_state.h | 22 +-
be/src/runtime/tablets_channel.cpp | 14 +-
.../aggregate_function_collect.h | 3 +-
be/src/vec/columns/column_decimal.cpp | 2 +-
be/src/vec/columns/column_object.cpp | 8 +-
be/src/vec/columns/column_vector.cpp | 2 +-
be/src/vec/common/assert_cast.h | 1 +
.../vec/data_types/serde/data_type_jsonb_serde.cpp | 4 +-
.../vec/data_types/serde/data_type_jsonb_serde.h | 3 +
.../data_types/serde/data_type_object_serde.cpp | 6 +
.../vec/data_types/serde/data_type_object_serde.h | 5 +-
.../file_reader/new_plain_text_line_reader.cpp | 13 +-
be/src/vec/exec/format/orc/vorc_reader.cpp | 8 +-
.../vec/exec/format/parquet/bool_plain_decoder.h | 3 +-
.../vec/exec/format/parquet/bool_rle_decoder.cpp | 24 +-
be/src/vec/exec/format/parquet/bool_rle_decoder.h | 5 +-
be/src/vec/exec/format/parquet/decoder.h | 6 +-
.../exec/format/parquet/delta_bit_pack_decoder.cpp | 134 ++
.../exec/format/parquet/delta_bit_pack_decoder.h | 176 +--
.../format/parquet/fix_length_dict_decoder.hpp | 6 +-
...e_metadata.cpp => fix_length_plain_decoder.cpp} | 38 +-
.../exec/format/parquet/fix_length_plain_decoder.h | 96 +-
be/src/vec/exec/format/parquet/level_decoder.cpp | 10 +-
.../vec/exec/format/parquet/parquet_thrift_util.h | 2 +-
.../parquet/vparquet_column_chunk_reader.cpp | 2 +-
.../exec/format/parquet/vparquet_file_metadata.cpp | 10 +-
.../exec/format/parquet/vparquet_file_metadata.h | 6 +-
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 3 +-
be/src/vec/exec/jni_connector.h | 2 +-
be/src/vec/exec/vtable_function_node.cpp | 3 +-
.../table_function/table_function_factory.cpp | 13 +-
.../exprs/table_function/table_function_factory.h | 17 +-
be/src/vec/exprs/table_function/vexplode_v2.cpp | 209 +++
.../table_function/vexplode_v2.h} | 40 +-
be/src/vec/functions/function_binary_arithmetic.h | 6 +-
be/src/vec/functions/function_cast.h | 15 +-
be/src/vec/functions/function_fake.cpp | 58 +-
be/src/vec/functions/function_json.cpp | 19 +-
be/src/vec/functions/function_string.cpp | 53 +-
be/src/vec/functions/function_string.h | 85 +-
be/src/vec/functions/functions_geo.cpp | 474 +++++--
be/src/vec/functions/functions_geo.h | 5 +-
be/src/vec/functions/simple_function_factory.h | 17 +-
be/src/vec/sink/vrow_distribution.cpp | 3 +
be/src/vec/sink/vrow_distribution.h | 3 +
be/src/vec/sink/writer/async_result_writer.cpp | 54 +-
.../writer/iceberg/viceberg_partition_writer.cpp | 3 +-
be/src/vec/sink/writer/vhive_partition_writer.cpp | 3 +-
be/src/vec/sink/writer/vtablet_writer.cpp | 9 +-
be/test/geo/geo_types_test.cpp | 1351 ++++++++++++++++++++
be/test/olap/txn_manager_test.cpp | 40 +
be/test/vec/columns/column_object_test.cpp | 37 +
be/test/vec/columns/common_column_test.h | 111 ++
.../format/parquet/bool_plain_decoder_test.cpp | 239 ++++
.../exec/format/parquet/bool_rle_decoder_test.cpp | 239 ++++
.../parquet/byte_array_dict_decoder_test.cpp | 500 ++++++++
.../parquet/byte_array_plain_decoder_test.cpp | 242 ++++
.../parquet/byte_stream_split_decoder_test.cpp | 395 ++++++
.../format/parquet/delta_bit_pack_decoder_test.cpp | 265 ++++
.../parquet/delta_byte_array_decoder_test.cpp | 588 +++++++++
.../delta_length_byte_array_decoder_test.cpp | 276 ++++
.../parquet/fix_length_dict_decoder_test.cpp | 538 ++++++++
.../parquet/fix_length_plain_decoder_test.cpp | 203 +++
.../vec/exec/format/parquet/level_decoder_test.cpp | 225 ++++
.../parquet/parquet_corrupt_statistics_test.cpp | 0
.../{ => format}/parquet/parquet_reader_test.cpp | 0
.../parquet/parquet_statistics_test.cpp | 0
.../{ => format}/parquet/parquet_thrift_test.cpp | 0
.../{ => format}/parquet/parquet_version_test.cpp | 0
be/test/vec/exec/orc/orc_convert_dict_test.cpp | 237 ++++
.../exec/orc/orc_convert_to_orc_literal_test.cpp | 216 ++++
be/test/vec/exec/orc/orc_memory_stream_test.h | 102 ++
be/test/vec/exec/orc/orc_reader_fill_data_test.cpp | 475 +++++++
.../vec/exec/orc/orc_reader_init_column_test.cpp | 359 ++++++
be/test/vec/function/function_geo_test.cpp | 151 ++-
be/test/vec/function/function_string_test.cpp | 17 +
be/test/vec/function/function_test_util.cpp | 95 +-
be/test/vec/function/function_test_util.h | 3 +-
be/test/vec/function/table_function_test.cpp | 163 ++-
build.sh | 2 +-
.../main/java/org/apache/doris/common/Config.java | 2 +-
.../java/org/apache/doris/alter/RollupJobV2.java | 6 +-
.../apache/doris/alter/SchemaChangeHandler.java | 18 +
.../org/apache/doris/analysis/CreateRoleStmt.java | 6 -
.../org/apache/doris/analysis/CreateUserStmt.java | 8 -
.../org/apache/doris/analysis/DropRoleStmt.java | 6 -
.../org/apache/doris/analysis/DropUserStmt.java | 7 -
.../apache/doris/analysis/FunctionCallExpr.java | 2 +
.../java/org/apache/doris/analysis/GrantStmt.java | 5 -
.../doris/analysis/LambdaFunctionCallExpr.java | 3 +
.../java/org/apache/doris/analysis/RevokeStmt.java | 5 -
.../java/org/apache/doris/binlog/DBBinlog.java | 9 +
.../doris/catalog/BuiltinScalarFunctions.java | 6 +
.../catalog/BuiltinTableGeneratingFunctions.java | 10 +
.../main/java/org/apache/doris/catalog/Env.java | 11 +-
.../java/org/apache/doris/catalog/OlapTable.java | 11 +-
.../org/apache/doris/common/util/LocationPath.java | 5 +-
.../apache/doris/common/util/PropertyAnalyzer.java | 6 +-
.../org/apache/doris/datasource/CatalogIf.java | 2 +-
.../org/apache/doris/datasource/CatalogMgr.java | 2 +-
.../apache/doris/datasource/ExternalCatalog.java | 25 +-
.../apache/doris/datasource/InternalCatalog.java | 2 +-
.../doris/datasource/hive/HMSExternalCatalog.java | 24 +-
.../doris/datasource/hive/HMSExternalTable.java | 23 +-
.../doris/datasource/hive/HiveMetaStoreCache.java | 13 +-
.../datasource/hive/ThriftHMSCachedClient.java | 2 +-
.../datasource/iceberg/IcebergExternalCatalog.java | 8 +
.../datasource/iceberg/IcebergMetadataOps.java | 3 +
.../doris/datasource/jdbc/JdbcExternalCatalog.java | 8 +-
.../doris/fs/remote/SwitchingFileSystem.java | 2 +-
.../main/java/org/apache/doris/load/ExportJob.java | 1 -
.../load/routineload/RoutineLoadTaskInfo.java | 7 +
.../org/apache/doris/mysql/AcceptListener.java | 12 +-
.../mysql/privilege/AccessControllerManager.java | 8 +-
.../org/apache/doris/nereids/parser/Dialect.java | 6 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 19 +-
.../post/CommonSubExpressionCollector.java | 24 +-
.../processor/post/CommonSubExpressionOpt.java | 2 +-
.../rules/analysis/EliminateGroupByConstant.java | 5 +-
.../expressions/functions/generator/Explode.java | 61 +-
.../generator/ExplodeJsonArrayJsonOuter.java | 4 +-
.../functions/generator/ExplodeOuter.java | 61 +-
.../expressions/functions/scalar/JsonArray.java | 33 +-
.../expressions/functions/scalar/JsonInsert.java | 33 +-
.../expressions/functions/scalar/JsonObject.java | 36 +-
.../expressions/functions/scalar/JsonReplace.java | 33 +-
.../expressions/functions/scalar/JsonSet.java | 33 +-
.../scalar/{JsonArray.java => StDisjoint.java} | 30 +-
.../scalar/{JsonArray.java => StIntersects.java} | 30 +-
.../scalar/{JsonArray.java => StTouches.java} | 30 +-
.../functions/scalar/SubstringIndex.java | 11 -
.../expressions/literal/StringLikeLiteral.java | 3 +-
.../expressions/visitor/ScalarFunctionVisitor.java | 15 +
.../persist/ReplacePartitionOperationLog.java | 18 +-
.../plugin/dialect/HttpDialectConverterPlugin.java | 2 +-
.../java/org/apache/doris/qe/ConnectScheduler.java | 14 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 15 +-
.../apache/doris/service/FrontendServiceImpl.java | 35 +-
.../sessions/FlightSessionsWithTokenManager.java | 20 +-
.../org/apache/doris/statistics/AnalysisJob.java | 6 +-
.../apache/doris/statistics/OlapAnalysisTask.java | 6 +-
.../apache/doris/common/util/LocationPathTest.java | 33 +-
.../doris/datasource/RefreshCatalogTest.java | 2 +-
.../postprocess/CommonSubExpressionTest.java | 46 +-
.../functions/generator/ExplodeOuterTest.java | 95 ++
.../functions/generator/ExplodeTest.java | 95 ++
.../expressions/literal/StringLikeLiteralTest.java | 7 +
.../doris/qe/StmtExecutorInternalQueryTest.java | 45 +
.../apache/doris/statistics/AnalysisJobTest.java | 27 +
.../doris/statistics/OlapAnalysisTaskTest.java | 8 +-
gensrc/thrift/FrontendService.thrift | 4 +
.../data/datatype_p0/complex_types/test.json | 3 +
.../hive/test_external_catalog_hive_partition.out | Bin 2711 -> 4455 bytes
.../hive/test_hive_get_schema_from_table.out | Bin 0 -> 6103 bytes
.../external_table_p0/tvf/lzo/test_compress.lzo | Bin 0 -> 256 bytes
.../test_no_compress_with_empty_block_begin.lzo | Bin 0 -> 200 bytes
.../lzo/test_no_compress_with_empty_block_end.lzo | Bin 0 -> 196 bytes
.../test_no_compress_with_empty_block_middle.lzo | Bin 0 -> 188 bytes
.../external_table_p0/tvf/test_local_tvf_lzo.out | Bin 0 -> 899 bytes
.../test_full_compaction_mow.out | Bin 0 -> 181 bytes
.../data/function_p0/test_substring_index.out | Bin 0 -> 2304 bytes
.../function_p0/test_substring_index_columns.out | Bin 0 -> 1124 bytes
.../function_p0/test_substring_index_simple.out | Bin 0 -> 725 bytes
.../create_without_distribute.out | Bin 0 -> 237 bytes
.../spatial_functions/test_gis_function.out | Bin 1438 -> 6671 bytes
...t_auto_partition_with_single_replica_insert.csv | 78 ++
...t_auto_partition_with_single_replica_insert.out | Bin 0 -> 7985 bytes
.../data/query_p0/aggregate/array_agg.out | Bin 8132 -> 8211 bytes
.../query_p0/cast/test_complextype_to_json.out | Bin 2450 -> 2124 bytes
.../json_function/test_query_json_array.out | Bin 485 -> 1395 bytes
.../json_function/test_query_json_insert.out | Bin 423 -> 1785 bytes
.../json_function/test_query_json_object.out | Bin 524 -> 1959 bytes
.../json_function/test_query_json_replace.out | Bin 543 -> 1752 bytes
.../json_function/test_query_json_set.out | Bin 385 -> 1594 bytes
.../spatial_functions/test_gis_function.out | Bin 1604 -> 2684 bytes
.../sql_functions/table_function/explode.out | Bin 25904 -> 27843 bytes
.../table_function/explode_json_array.out | Bin 6692 -> 6751 bytes
regression-test/data/variant_p0/cast.out | Bin 0 -> 247 bytes
.../data/variant_p0/sql/sort_permute.out | Bin 0 -> 24264 bytes
.../apache/doris/regression/suite/Syncer.groovy | 36 +-
.../test_backup_restore_schema_not_consist.groovy | 140 ++
.../add_drop_partition.groovy | 41 +-
.../add_drop_partition_by_hdfs.groovy | 60 +-
.../create_table_use_dynamic_partition.groovy | 38 +-
...eate_table_use_dynamic_partition_by_hdfs.groovy | 55 +-
.../create_table_use_partition_policy.groovy | 17 +-
...reate_table_use_partition_policy_by_hdfs.groovy | 25 +-
.../create_table_use_policy.groovy | 17 +-
.../create_table_use_policy_by_hdfs.groovy | 27 +-
.../load_colddata_to_hdfs.groovy | 22 +-
.../modify_replica_use_partition.groovy | 582 +++++----
.../modify_replica_use_partition_by_hdfs.groovy | 579 +++++----
.../table_modify_resouce_and_policy.groovy | 15 +-
.../table_modify_resouce_and_policy_by_hdfs.groovy | 23 +-
.../test_show_storage_policy_using.groovy | 2 +-
.../test_single_replica_compaction.groovy | 3 +-
.../test_fallback_to_legacy_planner.groovy | 90 ++
.../unique/test_unique_auto_inc_concurrent.groovy | 1 -
.../complex_types/test_load_with_functions.groovy | 81 ++
.../decimalv3/test_decimalv3_overflow.groovy | 1 -
.../test_external_catalog_hive_partition.groovy | 9 +
.../hive/test_hive_get_schema_from_table.groovy | 62 +
.../tvf/test_local_tvf_lzo.groovy | 58 +
.../test_full_compaction_mow.groovy | 98 ++
.../suites/function_p0/test_substring_index.groovy | 137 ++
.../test_substring_index_columns.groovy | 114 ++
.../function_p0/test_substring_index_simple.groovy | 89 ++
.../test_dup_table_inverted_index.groovy | 1 -
.../routine_load/test_routine_load_eof.groovy | 29 +-
.../create_without_distribute.groovy | 148 +++
.../mv_with_force_drop/mv_with_force_drop.groovy | 52 +
.../aggregate/aggregate_groupby_constant.groovy | 26 +
.../fold_constant_string_arithmatic.groovy | 288 ++---
.../spatial_functions/test_gis_function.groovy | 248 ++++
.../suites/nereids_rules_p0/cse/cse.groovy | 39 +-
...uto_partition_with_single_replica_insert.groovy | 78 ++
.../suites/query_p0/aggregate/array_agg.groovy | 29 +
.../json_function/test_query_json_array.groovy | 51 +
.../json_function/test_query_json_insert.groovy | 55 +
.../json_function/test_query_json_object.groovy | 56 +
.../json_function/test_query_json_replace.groovy | 55 +
.../json_function/test_query_json_set.groovy | 55 +
.../spatial_functions/test_gis_function.groovy | 81 ++
.../sql_functions/table_function/explode.groovy | 44 +
.../table_function/explode_array_decimal.groovy | 2 +-
.../table_function/explode_json_array.groovy | 29 +-
.../test_mow_time_series_compaction.groovy | 81 ++
regression-test/suites/variant_p0/cast.groovy | 60 +
.../suites/variant_p0/sql/sort_permute.sql | 1037 +++++++++++++++
.../suites/variant_p0/with_index/var_index.groovy | 24 +
thirdparty/CHANGELOG.md | 4 +
thirdparty/build-thirdparty.sh | 17 +-
thirdparty/vars.sh | 16 +-
tools/lzo/README.md | 37 +
tools/lzo/build.sh | 20 +
tools/lzo/lzo_writer.cpp | 282 ++++
265 files changed, 14904 insertions(+), 1933 deletions(-)
create mode 100644 be/src/vec/exec/format/parquet/delta_bit_pack_decoder.cpp
copy be/src/vec/exec/format/parquet/{vparquet_file_metadata.cpp =>
fix_length_plain_decoder.cpp} (52%)
create mode 100644 be/src/vec/exprs/table_function/vexplode_v2.cpp
copy be/src/vec/{exec/format/parquet/vparquet_file_metadata.h =>
exprs/table_function/vexplode_v2.h} (50%)
create mode 100644 be/test/vec/columns/common_column_test.h
create mode 100644 be/test/vec/exec/format/parquet/bool_plain_decoder_test.cpp
create mode 100644 be/test/vec/exec/format/parquet/bool_rle_decoder_test.cpp
create mode 100644
be/test/vec/exec/format/parquet/byte_array_dict_decoder_test.cpp
create mode 100644
be/test/vec/exec/format/parquet/byte_array_plain_decoder_test.cpp
create mode 100644
be/test/vec/exec/format/parquet/byte_stream_split_decoder_test.cpp
create mode 100644
be/test/vec/exec/format/parquet/delta_bit_pack_decoder_test.cpp
create mode 100644
be/test/vec/exec/format/parquet/delta_byte_array_decoder_test.cpp
create mode 100644
be/test/vec/exec/format/parquet/delta_length_byte_array_decoder_test.cpp
create mode 100644
be/test/vec/exec/format/parquet/fix_length_dict_decoder_test.cpp
create mode 100644
be/test/vec/exec/format/parquet/fix_length_plain_decoder_test.cpp
create mode 100644 be/test/vec/exec/format/parquet/level_decoder_test.cpp
rename be/test/vec/exec/{ =>
format}/parquet/parquet_corrupt_statistics_test.cpp (100%)
rename be/test/vec/exec/{ => format}/parquet/parquet_reader_test.cpp (100%)
rename be/test/vec/exec/{ => format}/parquet/parquet_statistics_test.cpp (100%)
rename be/test/vec/exec/{ => format}/parquet/parquet_thrift_test.cpp (100%)
rename be/test/vec/exec/{ => format}/parquet/parquet_version_test.cpp (100%)
create mode 100644 be/test/vec/exec/orc/orc_convert_dict_test.cpp
create mode 100644 be/test/vec/exec/orc/orc_convert_to_orc_literal_test.cpp
create mode 100644 be/test/vec/exec/orc/orc_memory_stream_test.h
create mode 100644 be/test/vec/exec/orc/orc_reader_fill_data_test.cpp
create mode 100644 be/test/vec/exec/orc/orc_reader_init_column_test.cpp
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{JsonArray.java
=> StDisjoint.java} (59%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{JsonArray.java
=> StIntersects.java} (59%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{JsonArray.java
=> StTouches.java} (60%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/generator/ExplodeOuterTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/generator/ExplodeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/qe/StmtExecutorInternalQueryTest.java
create mode 100644 regression-test/data/datatype_p0/complex_types/test.json
create mode 100644
regression-test/data/external_table_p0/hive/test_hive_get_schema_from_table.out
create mode 100644
regression-test/data/external_table_p0/tvf/lzo/test_compress.lzo
create mode 100644
regression-test/data/external_table_p0/tvf/lzo/test_no_compress_with_empty_block_begin.lzo
create mode 100644
regression-test/data/external_table_p0/tvf/lzo/test_no_compress_with_empty_block_end.lzo
create mode 100644
regression-test/data/external_table_p0/tvf/lzo/test_no_compress_with_empty_block_middle.lzo
create mode 100644
regression-test/data/external_table_p0/tvf/test_local_tvf_lzo.out
create mode 100644
regression-test/data/fault_injection_p0/test_full_compaction_mow.out
create mode 100644 regression-test/data/function_p0/test_substring_index.out
create mode 100644
regression-test/data/function_p0/test_substring_index_columns.out
create mode 100644
regression-test/data/function_p0/test_substring_index_simple.out
create mode 100644
regression-test/data/mtmv_p0/test_create_without_distribute/create_without_distribute.out
create mode 100644
regression-test/data/partition_p0/auto_partition/test_auto_partition_with_single_replica_insert.csv
create mode 100644
regression-test/data/partition_p0/auto_partition/test_auto_partition_with_single_replica_insert.out
create mode 100644 regression-test/data/variant_p0/cast.out
create mode 100644 regression-test/data/variant_p0/sql/sort_permute.out
create mode 100644
regression-test/suites/backup_restore/test_backup_restore_schema_not_consist.groovy
create mode 100644
regression-test/suites/correctness/test_fallback_to_legacy_planner.groovy
create mode 100644
regression-test/suites/datatype_p0/complex_types/test_load_with_functions.groovy
create mode 100644
regression-test/suites/external_table_p0/hive/test_hive_get_schema_from_table.groovy
create mode 100644
regression-test/suites/external_table_p0/tvf/test_local_tvf_lzo.groovy
create mode 100644
regression-test/suites/fault_injection_p0/test_full_compaction_mow.groovy
create mode 100644
regression-test/suites/function_p0/test_substring_index.groovy
create mode 100644
regression-test/suites/function_p0/test_substring_index_columns.groovy
create mode 100644
regression-test/suites/function_p0/test_substring_index_simple.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_create_without_distribute/create_without_distribute.groovy
create mode 100644
regression-test/suites/mv_p0/mv_with_force_drop/mv_with_force_drop.groovy
copy
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/literal/StringLikeLiteralTest.java
=> regression-test/suites/nereids_rules_p0/cse/cse.groovy (54%)
create mode 100644
regression-test/suites/partition_p0/auto_partition/test_auto_partition_with_single_replica_insert.groovy
create mode 100644
regression-test/suites/unique_with_mow_p0/test_mow_time_series_compaction.groovy
create mode 100644 regression-test/suites/variant_p0/cast.groovy
create mode 100644 regression-test/suites/variant_p0/sql/sort_permute.sql
create mode 100644 tools/lzo/README.md
create mode 100644 tools/lzo/build.sh
create mode 100644 tools/lzo/lzo_writer.cpp
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
