This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch auto-pick-60607-branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
from 568926b2fac [Fix](TabletHotspot) Fix race in
`TabletHotspot::get_top_n_hot_partition` (#60607)
add d189b9d9b52 [fix](test) Remove wrapper_field dependency from unit
tests (#60530) (#60593)
add 64892f5d261 branch-4.0: [Fix](func) fix element_at return err when
short-circuit evaluation passes empty input #60570 (#60595)
add f03c9e41ccf branch-4.0: [fix](s3)Use anonymous credentials for
S3-compatible storage when credentials are absent #60443 (#60613)
add edce88da8e0 branch-4.0: [Fix](datetime) fix %f (microseconds) format
specifier in str_to_date #60632 (#60642)
add 9bbaf875e6b branch-4.0: [fix](compile) fix MacOS compile backend
failed #60582 (#60620)
add d2ee9d84a3e branch-4.0: [fix](datetime) throw exception for
date_floor/ceil instead of return NULL #60633 (#60640)
add 902d8e58d5b branch-4.0: [Fix](Agg) Fix the problem that add_batch
cannot handle rows with null value correctly #60398 (#60604)
add 628263cf01a branch-4.0: [fix](cloud) Add error detail in tablet key
get failure message #60492 (#60597)
add 3265a9af3f0 branch-4.0: [Fix](RestCatalog)When vendor credentials are
configured at the catalog level, S3-compatible storage must also support
temporary credentials (#60232) (#60638)
add c01a0f26e52 branch-4.0: [Fix](dictionary) Fix empty
InsertIntoDictionaryCommand originSql #60631 (#60641)
add 9f38110eb66 branch-4.0: [opt](profile) change some metrics' level in
profile #60294 (#60653)
add 962c85b3761 branch-4.0: [opt](multi-catalog) Optimize file split size.
(#60637)
add 5f214b9521d branch-4.0: [fix](jni) fix JNI logging by migrating to
log4j2 with proper configuration #60584 (#60592)
add 0213008f7e7 branch-4.0: [Feature](Iceberg) Implement expire_snapshots
procedure for Iceberg tables #59979 (#60647)
add b1d881bf689 branch-4.0: [fix](test) fix unstable p2 cases (#60621)
(#60665)
add 343e3216b7e branch-4.0: [refine](function)In functions, ensure that an
empty input column returns an empty column. #60660 (#60696)
add e4207f6a6d7 branch-4.0: [fix](expr)Ensure short-circuit expressions
never receive a count of 0 #60594 (#60658)
add fb93bd37daf branch-4.0: [fix](nereids) Fix incorrect isDomain parsing
in SET PASSWORD statement #60565 (#60657)
add d2a73a13866 branch-4.0: [fix](nereids) fix empty layer in
CommonSubExpressionOpt when WhenClause is the only common sub-expression #60435
(#60619)
add 8cb910f6ac8 [pick](4.0) Use ColumnView to automatically handle
Nullable and Const, Fix array_join to handle non-constant columns. (#60707)
add c946cef4f41 branch-4.0: [test](sqlcache)Add sql cache with mtmv test
case #56753 (#60663)
add 490e098ffb4 branch-4.0: [fix](test) replace hardcoded IP with variable
in group commit redirect test #60573 (#60589)
add 7836fd2568b branch-4.0: [fix](regression-case) Fix routineload case :
test_routine_load_timeout_value #60664 (#60692)
add 64975c0e1ad branch-4.0: [fix](cloud) Fix CloudRowsetWriter vtable
use-after-free in delete bitmap task #60528 (#60708)
add 1b21d47b2b5 branch-4.0: [Fix](case) Fix unstale case
`test_ordered_compaction_num_seg_rows` due to be fuzzy config (#59970) (#60704)
add 4b3061c2d9f branch-4.0: (query cache) query cache shouldn't be hitted
when session variable changed or use udf (#60315) (#60661)
add 00ffd1ccd92 branch-4.0: [improve](log) Add segment file info when
bitshuffle page corruption detected #60547 (#60689)
add 0ae9ed206a6 branch-4.0: [Feature](func) Support function PREVIOUS_DAY
#60680 (#60726)
add 03af99507c3 branch-4.0: [fix](filecache) fix disk size calculation in
block_file_cache_factory #60644 (#60706)
add 85a1ea9a163 branch-4.0: [bugfix](k8s) fix log output for K8S
environment in cloud and add unit tests #60490 (#60678)
add 1507052edb9 branch-4.0: [fix](case) Fix `different_serialize_cloud`
case #59555 (#60675)
add 076332bb590 branch-4.0: [Fix](udf) fix frontends udf return rows
incompatible with show frontends command #60211 (#60602)
add 93277bde426 branch-4.0: [fix](cloud) Fix misleading CommittedVersion
display in show partitions #60623 (#60679)
add 84859cdf013 branch-4.0: [fix](regression) Fix case :
test_routine_load_adaptive_param #60673 (#60691)
add 0560eda8003 branch-4.0: [fix](custom analyzer) Fix basic and icu
tokenizer can not be customized #60506 (#60736)
add 37df2064d2a branch-4.0: [fix](iceberg) fix unstable iceberg case
#60646 (#60737)
add dce38b57051 branch-4.0: [fix](runtime) Clear
query_ctx_map_delay_delete in FragmentMgr::stop() to avoid UB #60718 (#60728)
add ccd1421cba3 branch-4.0: [fix](client) Handle empty S3 list page with
more results in concurrent deletion scenario #60332 (#60710)
add a12d20fffae branch-4.0: [test](nereids)fix sql cache of mtmv test case
#57177 (#60733)
add 427091c640e branch-4.0: [fix](CostBasedRewriteJob)restore
StatementContext.rewrittenCteProducer in CostBasedRewriteJob #59517 (#60742)
add 9817326de3e branch-4.0: [Feature](function) Support more INTERVAL
time-unit (#60347) (#60759)
add 866f1e7fd18 branch-4.0: [Enhancement](func) Add fold constant for
PREVIOUS_DAY #60755 (#60762)
add 51431716560 branch-4.0: [feature](geo) support 3 spatial functions:
ST_Distance, ST_GeometryType, ST_Length #60170 (#60748)
add 0067afdadd3 branch-4.0: [bugfix](k8s) fix Log4jConfig class loading
before Config.init in console mode #60531 (#60750)
add 47260908546 branch-4.0: [feat](libhdfs3) support
dfs.client.use.datanode.hostname for libhdfs3 #59915 (#60712)
add 1153e857641 branch-4.0: [feat](cloud) Enable split config by default
#60491 (#60596)
add a3faa308c02 branch-4.0: [test](nerieds)fix sql cache with mtmv test
case #57366 (#60760)
add 7c93ad9c4a5 branch-4.0: [fix](local exchange) Do global shuffle for
shuffled join/set operator #60758 (#60763)
add 801c9f4394d [fix](local exchange) Fix BUCKET_HASH_SHUFFLE partition
expr (#60765)
add 3dccd751b6c branch-4.0: [feature](multi-catalog) Add
max_file_split_num session variable to prevent OOM in file scan #58759 (#60732)
add 59bdb6099cf branch-4.0: [fix](schemachange) fix IndexChangeJob stuck
on WAITING_TXN due to exception #60754 (#60767)
add a433d82b316 branch-4.0: [fix](cloud) Fix disable_auto_compaction
property not taking effect in cloud mode #60544 (#60771)
add ee6b9e8bab7 branch-4.0: [Fix](keywords) add composite time units to
nonReserved #60775 (#60778)
add 3677055f071 branch-4.0: [fix](function)width_bucket did not enforce
that the fourth argument must be a constant. #60643 (#60794)
add 76073b41b7d branch-4.0: [fix](core)Fix a DCHECK failure when
short-circuit evaluation and array_map are used together. #60693 (#60800)
add 5a243f57f4c branch-4.0: [Improve](streaming job) support postgres
partition table sync #60560 (#60614)
add a133581f24d branch-4.0: [fix](iterator) Use explicit output schema in
new_merge_iterator and new_union_iterator #60772 (#60804)
add ce72b33eef2 branch-4.0: [fix](search) Validate mode parameter in
search() DSL options #60785 (#60813)
add cc01c04f4c9 branch-4.0: [fix](ann range search) range search prepare
failed on NULL literal #60564 (#60821)
add 7362354a53e branch-4.0: [Opt](function) opt of certain time field
functions used in conjunction with FROM_UNIXTIME. (#60843)
add 3541a6da7a6 branch-4.0: [fix](load) fix quorum success invalid in
move-memtable-on-sink load path #60681 (#60820)
add f366aefa17f branch-4.0: [Fix](regexp) make dot match newline in
regexp_fn by default #60831 (#60853)
add d871ebeeb1b branch-4.0: [test](sqlcache)fix sql cache test case #58079
(#60848)
add 6e2074ac13d branch-4.0: [fix](agg) Fix distinct streaming agg #60851
(#60860)
add b8ceb5966fc branch-4.0: [fix](auth) delete command improperly detects
the LOAD permission of non target tables #60837 (#60863)
add 2fae65f6089 branch-4.0: [Bug](distinct) Fixes off-by-one error in
aggregation limit check #60828 (#60868)
add f142279a779 branch-4.0: [fix](storage vault) fix Azure Storage Vault
endpoint always using HTTP instead of HTTPS #60854 (#60861)
add 8989e23cb9c branch-4.0: [Fix](nereids) Fix session variable not take
effect for partial update in multi-statement batch #60803 (#60862)
add 16b4d60a26a branch-4.0: [Fix](DDL) Make autoBucket flag modifiable and
add testcases for ALTER TABLE BUCKETS #60651 (#60825)
add 3f86beca843 branch-4.0: [fix](iceberg) Invalidate related-table cache
on external table refresh #60867 (#60885)
add 1574f937eb8 [fix](paimon) add rest external catalog for gson
comaptiblity (#60917)
add b69a454d574 cherry-pick branch4.0 : [fix](variant) Disable strict mode
for variant internal cast to fix INSERT INTO SELECT returning all NULLs
(#60900)
add 2b7bc87022e branch-4.0: [fix](cloud) Fix packed file write path
bypassing encryption #60629 (#60869)
add f63a43f037f branch-4.0: [fix](recycler) Fix metrics statistics issues
in recycler workflows #60697 (#60933)
add bd23cb694a4 branch-4.0: [feature](storage) Add OzoneProperties to
support Apache Ozone #60809 (#60896)
add 5c97bb56e1f branch-4.0: [bug](udf) udf should cache classloader in
static load #60709 (#60975)
add 832fec6b59a branch-4.0: [fix](insert-overwrite) skip deleted
partitions before replace to avoid DdlException #60914 (#60949)
add 04f5bad7e83 branch-4.0: [check](column)const is only allowed at the
top level. #60578 (#60959)
add 0875f9bcaf9 branch-4.0: [fix](priv) skip catalog priv check if using
customized access controller #60945 (#60962)
add 02110dc38a5 branch-4.0: [fix](jdbc) Fix PG array null detection and
SQL Server date format pushdown #60954 (#60972)
add add05a81297 branch-4.0: [fix](be) Default to the Default chain when S3
role_arn is set without provider_type #60822 (#60965)
add c6fb1f1ce6a branch-4.0: [Opt](warmup) Limit the download rate of
warmup task (#60180) (#60841)
add b528318a55a [branch-4.0] [fix](cloud) Fix SingleFlight deadlock in
CloudTabletMgr::get_tablet during warmup (#60968)
add 73fb086c878 branch-4.0: [test](nerieds)fix sql cache with mtmv test
case #58236 (#60956)
add 2e32f786476 branch-4.0: [fix](cloud) Fix auto-start functionality when
encountering TVF and external queries #59963 (#60802)
add 029ee014baf branch-4.0: [fix](parquet)fix parquet reader lazy
materialization cannot filter. #60474 (#60685)
add 6b1dc8d9c49 [fix](filecache) avoid string_view::data() in
file_cache_action (#60101) (#60549)
add e0690d046ef [refactor](cloud) improve FDB transaction approximate size
calculation accuracy (#60390)
add a205a3620de [fix](filecache) reset_range dose not update shadow queue
causing lar… (#60554)
add c2ef7a54be4 branch-4.0:[feature](maxcompute)support maxcompute
ram_role_arn and ecs_ram_role.(#60649) (#60905)
add 912ebd1ac92 branch-4.0: [fix](stream-load) Fix LZ4 compressed stream
load decompress made no progress error #60852 (#60980)
add 1d68ca85cb2 branch-4.0: [Bug](join) fix left_semi_direct_return_opt
get wrong result with local shuffle #60952 (#60984)
add acc85ec6eff branch-4.0: [fix](point-query) Fix point query ignoring
session timezone for functions like from_unixtime #60913 (#60991)
add 581c3c12900 branch-4.0:[fix](case)fix some external regression test.
(#60744) (#60992)
add 8f31cee1adb branch-4.0: [Feature](iceberg) Support schema change for
complex types in Iceberg external tables #60169 (#60993)
add 0461cae28d7 branch-4.0: [improve](cloud) reduce fe call get_version to
meta_service #60467 (#60948)
add 5196ac2bd1d branch-4.0: [refactor](search) Refactor SearchDslParser to
single-phase ANTLR parsing #60635 (#60998)
add 240b8fa67c5 branch-4.0: [fix](search) Make AND/OR/NOT operators
case-sensitive in search DSL #59747 (#61012)
add 962222e8426 branch-4.0: [Fix](Cloud)decouple min pipeline executor
size from ConnectContext #60958 (#61005)
add b358eafb4f3 branch-4.0: [fix](Azure)Fix Azure endpoint detection for
sovereign clouds with force-global config support #60903 (#61006)
add 5bb85e7830d [feature](bm25) support score range filter pushdown
(min_score semantics) (#60997)
add 03a6aa432c3 branch-4.0: [fix](test) add more log to debug #61009
(#61010)
add 67acef4b406 Merge branch 'branch-4.0' into auto-pick-60607-branch-4.0
No new revisions were added by this update.
Summary of changes:
be/src/cloud/cloud_rowset_writer.cpp | 35 +-
be/src/cloud/cloud_tablet.cpp | 10 +
be/src/cloud/config.cpp | 4 +
be/src/cloud/config.h | 4 +
be/src/common/config.cpp | 11 +-
be/src/common/config.h | 41 +-
be/src/exec/rowid_fetcher.h | 1 +
be/src/geo/geo_types.cpp | 371 ++++++
be/src/geo/geo_types.h | 26 +-
be/src/http/action/file_cache_action.cpp | 27 +-
be/src/io/cache/block_file_cache.cpp | 25 +-
be/src/io/cache/block_file_cache_factory.cpp | 6 +-
be/src/io/cache/cached_remote_file_reader.cpp | 11 +
be/src/io/cache/file_cache_common.h | 2 +
be/src/io/cache/fs_file_cache_storage.cpp | 23 +-
be/src/io/cache/fs_file_cache_storage.h | 4 +
be/src/io/cache/lru_queue_recorder.cpp | 13 +-
be/src/io/cache/lru_queue_recorder.h | 3 +-
be/src/io/fs/azure_obj_storage_client.cpp | 3 -
be/src/io/fs/file_writer.h | 4 +
be/src/io/fs/packed_file_writer.h | 3 +
be/src/olap/accept_null_predicate.h | 1 -
be/src/olap/bitmap_filter_predicate.h | 1 -
be/src/olap/collection_similarity.cpp | 96 +-
be/src/olap/collection_similarity.h | 22 +-
be/src/olap/column_mapping.h | 4 +-
be/src/olap/comparison_predicate.h | 1 -
be/src/olap/in_list_predicate.h | 1 -
be/src/olap/null_predicate.h | 2 +-
be/src/olap/rowset/beta_rowset_reader.cpp | 13 +-
be/src/olap/rowset/beta_rowset_reader.h | 10 +
be/src/olap/rowset/rowset_meta.cpp | 8 +-
be/src/olap/rowset/rowset_meta.h | 7 +
be/src/olap/rowset/rowset_writer_context.h | 12 +-
be/src/olap/rowset/segment_v2/bitshuffle_page.h | 8 +-
be/src/olap/rowset/segment_v2/column_reader.cpp | 207 +--
be/src/olap/rowset/segment_v2/column_reader.h | 18 +-
.../rowset/segment_v2/indexed_column_reader.cpp | 5 +
be/src/olap/rowset/segment_v2/segment.cpp | 2 +-
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 46 +-
be/src/olap/schema_change.cpp | 69 +-
be/src/olap/shared_predicate.h | 1 -
be/src/olap/tablet_schema.cpp | 4 +-
be/src/olap/tablet_schema.h | 2 +-
be/src/olap/wrapper_field.cpp | 112 --
be/src/olap/wrapper_field.h | 107 --
.../distinct_streaming_aggregation_operator.cpp | 4 +-
.../exec/distinct_streaming_aggregation_operator.h | 3 +
be/src/pipeline/exec/hashjoin_build_sink.h | 4 +
be/src/pipeline/exec/hashjoin_probe_operator.h | 4 +
be/src/pipeline/exec/olap_scan_operator.cpp | 11 +
be/src/pipeline/exec/operator.h | 6 +-
.../exec/partitioned_hash_join_probe_operator.h | 3 +
.../exec/partitioned_hash_join_sink_operator.h | 3 +
be/src/pipeline/exec/set_probe_sink_operator.h | 4 +
be/src/pipeline/exec/set_sink_operator.h | 4 +
be/src/pipeline/pipeline_fragment_context.cpp | 49 +-
be/src/pipeline/pipeline_fragment_context.h | 11 +-
be/src/runtime/descriptors.cpp | 9 +
be/src/runtime/descriptors.h | 10 +-
be/src/runtime/exec_env.h | 3 +
be/src/runtime/exec_env_init.cpp | 46 +
be/src/runtime/fragment_mgr.cpp | 4 +
be/src/runtime/load_stream.cpp | 1 +
be/src/runtime/runtime_state.h | 5 +
be/src/runtime_filter/runtime_filter_consumer.cpp | 4 +-
be/src/runtime_filter/runtime_filter_producer.cpp | 13 +-
be/src/runtime_filter/runtime_filter_producer.h | 18 +-
.../runtime_filter_producer_helper.cpp | 2 +-
be/src/runtime_filter/runtime_filter_wrapper.cpp | 3 +-
be/src/service/point_query_executor.cpp | 4 +
be/src/util/s3_util.cpp | 14 +-
.../aggregate_functions/aggregate_function_null.h | 4 +-
.../aggregate_functions/aggregate_function_sort.h | 2 +-
be/src/vec/columns/column.cpp | 11 +
be/src/vec/columns/column.h | 12 +
be/src/vec/columns/column_array.cpp | 4 +-
be/src/vec/columns/column_execute_util.h | 101 ++
be/src/vec/columns/column_map.cpp | 1 +
be/src/vec/columns/column_nothing.h | 2 +-
be/src/vec/columns/column_nullable.cpp | 14 +-
be/src/vec/columns/column_nullable.h | 1 +
be/src/vec/columns/column_string.cpp | 14 -
be/src/vec/columns/column_string.h | 14 +-
be/src/vec/columns/column_struct.cpp | 1 +
be/src/vec/columns/predicate_column.h | 22 +
be/src/vec/common/cow.h | 7 +-
be/src/vec/common/string_ref.cpp | 11 +
be/src/vec/common/string_ref.h | 1 +
be/src/vec/data_types/data_type_factory.hpp | 4 +-
.../vec/data_types/data_type_fixed_length_object.h | 2 +-
be/src/vec/data_types/data_type_string.h | 2 +-
.../data_types/serde/data_type_bitmap_serde.cpp | 4 +-
.../vec/data_types/serde/data_type_bitmap_serde.h | 4 +-
.../serde/data_type_date_or_datetime_serde.cpp | 4 +-
.../serde/data_type_date_or_datetime_serde.h | 4 +-
.../serde/data_type_datetimev2_serde.cpp | 4 +-
.../data_types/serde/data_type_datetimev2_serde.h | 4 +-
.../data_types/serde/data_type_datev2_serde.cpp | 4 +-
.../vec/data_types/serde/data_type_datev2_serde.h | 4 +-
.../data_types/serde/data_type_decimal_serde.cpp | 12 +-
.../vec/data_types/serde/data_type_decimal_serde.h | 4 +-
.../vec/data_types/serde/data_type_hll_serde.cpp | 4 +-
be/src/vec/data_types/serde/data_type_hll_serde.h | 4 +-
.../vec/data_types/serde/data_type_ipv4_serde.cpp | 4 +-
be/src/vec/data_types/serde/data_type_ipv4_serde.h | 4 +-
.../vec/data_types/serde/data_type_ipv6_serde.cpp | 4 +-
be/src/vec/data_types/serde/data_type_ipv6_serde.h | 4 +-
.../vec/data_types/serde/data_type_jsonb_serde.h | 2 +-
.../data_types/serde/data_type_nullable_serde.cpp | 7 +-
.../data_types/serde/data_type_nullable_serde.h | 4 +-
.../data_types/serde/data_type_number_serde.cpp | 4 +-
.../vec/data_types/serde/data_type_number_serde.h | 4 +-
.../serde/data_type_quantilestate_serde.cpp | 4 +-
.../serde/data_type_quantilestate_serde.h | 4 +-
be/src/vec/data_types/serde/data_type_serde.h | 14 +-
.../data_types/serde/data_type_string_serde.cpp | 13 +-
.../vec/data_types/serde/data_type_string_serde.h | 11 +-
.../vec/data_types/serde/data_type_time_serde.cpp | 4 +-
be/src/vec/data_types/serde/data_type_time_serde.h | 4 +-
.../serde/data_type_timestamptz_serde.cpp | 4 +-
.../data_types/serde/data_type_timestamptz_serde.h | 4 +-
be/src/vec/exec/format/csv/csv_reader.cpp | 2 +-
.../file_reader/new_plain_text_line_reader.cpp | 9 +-
.../exec/format/parquet/vparquet_group_reader.cpp | 1 -
.../exec/format/table/max_compute_jni_reader.cpp | 34 +-
be/src/vec/exec/format/text/text_reader.cpp | 2 +-
be/src/vec/exec/scan/file_scanner.cpp | 14 +-
be/src/vec/exec/scan/file_scanner.h | 3 +-
be/src/vec/exec/scan/olap_scanner.cpp | 2 -
be/src/vec/exec/scan/scanner_scheduler.cpp | 4 +
.../exprs/lambda_function/varray_map_function.cpp | 4 +-
be/src/vec/exprs/score_runtime.h | 22 +
be/src/vec/exprs/short_circuit_evaluation_expr.cpp | 79 +-
be/src/vec/exprs/vectorized_fn_call.cpp | 105 +-
.../vec/functions/array/function_array_element.h | 7 -
be/src/vec/functions/array/function_array_join.h | 126 +-
be/src/vec/functions/cast/cast_to_variant.h | 4 +-
be/src/vec/functions/date_format_type.h | 148 +++
be/src/vec/functions/date_time_transforms.h | 184 +++
be/src/vec/functions/datetime_errors.h | 32 +-
be/src/vec/functions/function.h | 10 +
be/src/vec/functions/function_const.h | 3 +-
.../function_date_or_datetime_computation.cpp | 64 +-
.../function_date_or_datetime_computation.h | 680 +++++-----
.../function_date_or_datetime_to_string.cpp | 22 +
be/src/vec/functions/function_regexp.cpp | 1 +
.../vec/functions/function_time_value_to_field.cpp | 10 +
be/src/vec/functions/function_width_bucket.cpp | 3 +-
be/src/vec/functions/functions_geo.cpp | 532 ++++----
be/src/vec/olap/vgeneric_iterators.cpp | 63 +-
be/src/vec/olap/vgeneric_iterators.h | 50 +-
be/src/vec/runtime/vdatetime_value.cpp | 35 +-
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 4 +-
be/test/cloud/cloud_tablet_test.cpp | 267 ++++
be/test/common/config_on_update_test.cpp | 147 +++
be/test/common/logconfig_test.cpp | 264 ++++
be/test/geo/geo_types_test.cpp | 534 ++++++++
be/test/io/s3_client_factory_test.cpp | 243 +++-
be/test/olap/collection_similarity_test.cpp | 541 ++++++++
be/test/vec/columns/column_array_test.cpp | 73 +-
.../column_check_const_only_in_top_level_test.cpp | 311 +++++
be/test/vec/columns/column_execute_util_test.cpp | 164 +++
be/test/vec/data_types/from_string_test.cpp | 205 +--
.../data_types/serde/data_type_serde_csv_test.cpp | 32 +-
.../data_type_serde_fixed_length_object_test.cpp | 15 +-
.../data_types/serde/data_type_serde_map_test.cpp | 4 +-
.../serde/data_type_serde_string_test.cpp | 2 +-
.../serde/data_type_serde_struct_test.cpp | 2 +-
.../data_types/serde/data_type_serde_text_test.cpp | 29 +-
be/test/vec/exec/vgeneric_iterators_test.cpp | 17 +-
be/test/vec/exprs/score_runtime_test.cpp | 259 ++++
.../function/cast/function_variant_cast_test.cpp | 148 +++
be/test/vec/function/function_time_test.cpp | 668 ++++++++++
cloud/script/start.sh | 4 +-
cloud/src/common/config.h | 4 +-
cloud/src/common/logging.cpp | 72 +-
cloud/src/meta-service/meta_service.cpp | 35 +-
cloud/src/meta-service/meta_service.h | 3 +-
cloud/src/meta-service/meta_service_partition.cpp | 141 +-
cloud/src/meta-service/meta_service_txn.cpp | 184 ++-
cloud/src/meta-store/txn_kv.cpp | 72 +-
cloud/src/recycler/recycler.cpp | 32 +-
cloud/src/recycler/recycler.h | 8 +-
cloud/src/recycler/s3_accessor.cpp | 10 +-
cloud/src/recycler/s3_obj_client.cpp | 17 +-
cloud/test/log_test.cpp | 205 +++
cloud/test/meta_service_test.cpp | 37 +-
cloud/test/meta_service_versioned_read_test.cpp | 39 +
cloud/test/s3_accessor_client_test.cpp | 13 +-
cloud/test/schema_kv_test.cpp | 167 ++-
cloud/test/txn_lazy_commit_test.cpp | 38 +
.../postgresql/init/02-create-table.sql | 7 +-
.../docker-compose/postgresql/init/04-insert.sql | 5 +
.../sqlserver/init/03-create-table.sql | 7 +
.../docker-compose/sqlserver/init/04-insert.sql | 9 +
.../doris/common/classloader/ScannerLoader.java | 68 +-
.../apache/doris/common/jni/utils/ExpiringMap.java | 19 +-
.../doris/common/jni/utils/UdfClassCache.java | 24 +-
.../java-common/src/main/resources/log4j2.xml | 63 +
.../java/org/apache/doris/udf/BaseExecutor.java | 27 +-
.../java/org/apache/doris/udf/UdafExecutor.java | 7 +-
.../java/org/apache/doris/udf/UdfExecutor.java | 10 +-
.../doris/maxcompute/MaxComputeJniScanner.java | 10 +-
.../doris/trinoconnector/TrinoConnectorCache.java | 15 +-
.../trinoconnector/TrinoConnectorPluginLoader.java | 29 +-
fe/fe-common/pom.xml | 14 +
.../main/java/org/apache/doris/common/Config.java | 48 +-
.../doris/common/maxcompute}/MCProperties.java | 19 +-
.../apache/doris/common/maxcompute/MCUtils.java | 78 ++
.../antlr4/org/apache/doris/nereids/DorisLexer.g4 | 14 +-
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 24 +-
.../org/apache/doris/nereids/search/SearchLexer.g4 | 6 +-
.../apache/doris/nereids/search/SearchParser.g4 | 10 +-
.../src/main/java/org/apache/doris/DorisFE.java | 9 +-
.../org/apache/doris/alter/IndexChangeJob.java | 3 +
.../org/apache/doris/analysis/DateLiteral.java | 4 +-
.../apache/doris/blockrule/SqlBlockRuleMgr.java | 3 +
.../org/apache/doris/catalog/AzureResource.java | 4 +-
.../doris/catalog/BuiltinScalarFunctions.java | 38 +
.../java/org/apache/doris/catalog/ColumnType.java | 65 +-
.../org/apache/doris/catalog/DistributionInfo.java | 10 +-
.../main/java/org/apache/doris/catalog/Env.java | 4 +
.../apache/doris/catalog/HashDistributionInfo.java | 10 -
.../java/org/apache/doris/catalog/OlapTable.java | 76 +-
.../doris/catalog/RandomDistributionInfo.java | 5 -
.../org/apache/doris/catalog/RefreshManager.java | 6 +
.../doris/clone/DynamicPartitionScheduler.java | 2 +-
.../org/apache/doris/cloud/catalog/CloudEnv.java | 11 +-
.../cloud/catalog/CloudFEVersionSynchronizer.java | 220 ++++
.../apache/doris/cloud/catalog/CloudPartition.java | 58 +-
.../cloud/catalog/CloudSyncVersionDaemon.java | 203 +++
.../cloud/datasource/CloudInternalCatalog.java | 52 +-
.../doris/cloud/system/CloudSystemInfoService.java | 224 +++-
.../transaction/CloudGlobalTransactionMgr.java | 122 +-
.../java/org/apache/doris/common/ClientPool.java | 3 +
.../doris/common/proc/FrontendsProcNode.java | 16 +-
.../doris/common/proc/PartitionsProcDir.java | 74 +-
.../doris/common/profile/RuntimeProfile.java | 3 +-
.../doris/common/profile/SummaryProfile.java | 9 +
.../org/apache/doris/common/util/LocationPath.java | 4 +
.../org/apache/doris/common/util/PrintableMap.java | 2 +-
.../apache/doris/datasource/ExternalScanNode.java | 12 +-
.../doris/datasource/FederationBackendPolicy.java | 12 +-
.../apache/doris/datasource/FileQueryScanNode.java | 35 +-
.../org/apache/doris/datasource/FileScanNode.java | 22 +-
.../org/apache/doris/datasource/FileSplitter.java | 230 +++-
.../apache/doris/datasource/InternalCatalog.java | 13 +-
.../apache/doris/datasource/SplitGenerator.java | 2 +-
.../doris/source/RemoteDorisScanNode.java | 6 +-
.../doris/datasource/es/source/EsScanNode.java | 5 +-
.../doris/datasource/hive/source/HiveScanNode.java | 96 +-
.../doris/datasource/hudi/source/HudiScanNode.java | 6 +-
.../datasource/iceberg/IcebergMetadataOps.java | 223 +++-
.../action/IcebergExpireSnapshotsAction.java | 221 +++-
.../iceberg/rewrite/RewriteGroupTask.java | 3 +-
.../datasource/iceberg/source/IcebergScanNode.java | 97 +-
.../jdbc/client/JdbcPostgreSQLClient.java | 6 +-
.../doris/datasource/jdbc/source/JdbcScanNode.java | 35 +-
.../lakesoul/source/LakeSoulScanNode.java | 7 +-
.../maxcompute/MaxComputeExternalCatalog.java | 33 +-
.../maxcompute/MaxComputeExternalTable.java | 8 +-
.../maxcompute/source/MaxComputeScanNode.java | 15 +-
.../doris/datasource/odbc/source/OdbcScanNode.java | 11 +-
.../paimon/PaimonRestExternalCatalog.java} | 29 +-
.../datasource/paimon/source/PaimonScanNode.java | 59 +-
.../storage/AbstractS3CompatibleProperties.java | 12 +
.../property/storage/AzureProperties.java | 39 +-
.../property/storage/AzurePropertyUtils.java | 63 +-
.../datasource/property/storage/COSProperties.java | 8 +-
.../property/storage/MinioProperties.java | 8 +-
.../datasource/property/storage/OBSProperties.java | 8 +-
.../datasource/property/storage/OSSProperties.java | 10 +-
.../property/storage/OzoneProperties.java | 153 +++
.../datasource/property/storage/S3Properties.java | 10 +-
.../property/storage/StorageProperties.java | 6 +-
.../source/TrinoConnectorScanNode.java | 7 +-
.../datasource/tvf/source/MetadataScanNode.java | 6 +-
.../doris/datasource/tvf/source/TVFScanNode.java | 41 +-
.../apache/doris/dictionary/DictionaryManager.java | 10 +-
.../apache/doris/indexpolicy/IndexPolicyMgr.java | 6 +
.../doris/insertoverwrite/InsertOverwriteUtil.java | 13 +-
.../insert/streaming/StreamingMultiTblTask.java | 4 +-
.../doris/load/routineload/KafkaTaskInfo.java | 4 +-
.../mysql/privilege/AccessControllerManager.java | 28 +-
.../org/apache/doris/nereids/StatementContext.java | 160 ++-
.../doris/nereids/analyzer/UnboundTableSink.java | 6 +-
.../org/apache/doris/nereids/cost/CostModel.java | 3 +-
.../doris/nereids/errors/QueryPlanningErrors.java | 8 +-
.../glue/translator/PhysicalPlanTranslator.java | 139 +-
.../glue/translator/PlanTranslatorContext.java | 21 +
.../nereids/jobs/rewrite/CostBasedRewriteJob.java | 27 +-
.../doris/nereids/jobs/rewrite/RewriteJob.java | 14 +-
.../nereids/jobs/scheduler/SimpleJobScheduler.java | 14 +-
.../nereids/load/NereidsLoadingTaskPlanner.java | 6 +-
.../nereids/load/NereidsStreamLoadPlanner.java | 6 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 8 +-
.../post/CommonSubExpressionCollector.java | 2 +
.../processor/post/CommonSubExpressionOpt.java | 16 +-
.../properties/ChildrenPropertiesRegulator.java | 7 +-
.../rules/analysis/DatetimeFunctionBinder.java | 54 +
.../rules/expression/ExpressionOptimization.java | 2 +
.../rules/expression/ExpressionRuleType.java | 1 +
.../rules/SimplifyTimeFieldFromUnixtime.java | 151 +++
.../LogicalOlapScanToPhysicalOlapScan.java | 1 +
.../rewrite/PushDownScoreTopNIntoOlapScan.java | 176 ++-
.../rewrite/PushDownVectorTopNIntoOlapScan.java | 2 +-
.../doris/nereids/rules/rewrite/SaltJoin.java | 4 +-
.../trees/expressions/ComparisonPredicate.java | 18 +
.../functions/executable/DateTimeArithmetic.java | 497 ++++++-
.../executable/DateTimeExtractAndTransform.java | 181 +++
.../functions/executable/TimeRoundSeries.java | 4 +-
.../expressions/functions/scalar/DayHour.java | 66 +
.../expressions/functions/scalar/DayHourSub.java | 84 ++
.../functions/scalar/DayMicrosecond.java | 66 +
.../functions/scalar/DayMicrosecondAdd.java | 85 ++
.../functions/scalar/DayMicrosecondSub.java | 85 ++
.../expressions/functions/scalar/DayMinute.java | 66 +
.../expressions/functions/scalar/DayMinuteAdd.java | 84 ++
.../expressions/functions/scalar/DayMinuteSub.java | 84 ++
.../expressions/functions/scalar/DaySecond.java | 66 +
.../expressions/functions/scalar/DaySecondSub.java | 84 ++
.../{WidthBucket.java => HourFromUnixtime.java} | 43 +-
.../functions/scalar/HourMicrosecond.java | 66 +
.../functions/scalar/HourMicrosecondAdd.java | 85 ++
.../functions/scalar/HourMicrosecondSub.java | 85 ++
.../expressions/functions/scalar/HourMinute.java | 66 +
.../functions/scalar/HourMinuteAdd.java | 84 ++
.../functions/scalar/HourMinuteSub.java | 84 ++
.../expressions/functions/scalar/HourSecond.java | 66 +
.../functions/scalar/HourSecondAdd.java | 84 ++
.../functions/scalar/HourSecondSub.java | 84 ++
.../functions/scalar/MicrosecondFromUnixtime.java | 83 ++
.../{WidthBucket.java => MinuteFromUnixtime.java} | 43 +-
.../functions/scalar/MinuteMicrosecond.java | 66 +
.../functions/scalar/MinuteMicrosecondAdd.java | 85 ++
.../functions/scalar/MinuteMicrosecondSub.java | 85 ++
.../expressions/functions/scalar/MinuteSecond.java | 66 +
.../functions/scalar/MinuteSecondSub.java | 84 ++
.../expressions/functions/scalar/PreviousDay.java | 67 +
.../functions/scalar/SearchDslParser.java | 1369 ++++++++++----------
.../{WidthBucket.java => SecondFromUnixtime.java} | 43 +-
.../functions/scalar/SecondMicrosecond.java | 66 +
.../functions/scalar/SecondMicrosecondSub.java | 88 ++
.../expressions/functions/scalar/StDistance.java | 75 ++
.../functions/scalar/StGeometryType.java | 74 ++
.../expressions/functions/scalar/StLength.java | 75 ++
.../expressions/functions/scalar/WidthBucket.java | 13 +
.../expressions/functions/scalar/YearMonth.java | 73 ++
.../expressions/functions/scalar/YearMonthAdd.java | 84 ++
.../expressions/functions/scalar/YearMonthSub.java | 84 ++
.../trees/expressions/literal/Interval.java | 17 +-
.../expressions/visitor/ScalarFunctionVisitor.java | 193 ++-
.../doris/nereids/trees/plans/ScoreRangeInfo.java | 79 ++
.../trees/plans/commands/DeleteFromCommand.java | 53 +-
.../trees/plans/commands/SetOptionsCommand.java | 4 +
.../trees/plans/commands/ShowFrontendsCommand.java | 6 +-
.../trees/plans/commands/info/SetPassVarOp.java | 4 +
.../trees/plans/commands/insert/InsertUtils.java | 13 +
.../trees/plans/logical/LogicalOlapScan.java | 75 +-
.../physical/PhysicalLazyMaterializeOlapScan.java | 1 +
.../trees/plans/physical/PhysicalOlapScan.java | 34 +-
.../org/apache/doris/nereids/util/DateUtils.java | 4 +-
.../org/apache/doris/persist/gson/GsonUtils.java | 2 +
.../org/apache/doris/planner/AggregationNode.java | 10 +
.../planner/BackendPartitionedSchemaScanNode.java | 5 +-
.../java/org/apache/doris/planner/CTEScanNode.java | 4 +-
.../org/apache/doris/planner/DataGenScanNode.java | 10 +-
.../org/apache/doris/planner/FileLoadScanNode.java | 4 +-
.../apache/doris/planner/GroupCommitScanNode.java | 5 +-
.../org/apache/doris/planner/OlapScanNode.java | 18 +-
.../org/apache/doris/planner/PlanFragment.java | 6 +-
.../java/org/apache/doris/planner/ScanContext.java | 58 +
.../java/org/apache/doris/planner/ScanNode.java | 27 +-
.../org/apache/doris/planner/SchemaScanNode.java | 5 +-
.../planner/normalize/QueryCacheNormalizer.java | 35 +-
.../org/apache/doris/qe/PointQueryExecutor.java | 6 +
.../java/org/apache/doris/qe/SessionVariable.java | 121 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 4 +-
.../apache/doris/service/FrontendServiceImpl.java | 12 +
.../org/apache/doris/system/SystemInfoService.java | 4 +-
.../tablefunction/DataGenTableValuedFunction.java | 4 +-
.../ExternalFileTableValuedFunction.java | 5 +-
.../FrontendsDisksTableValuedFunction.java | 11 +
.../FrontendsTableValuedFunction.java | 16 +-
.../GroupCommitTableValuedFunction.java | 4 +-
.../tablefunction/JdbcQueryTableValueFunction.java | 4 +-
.../tablefunction/MetadataTableValuedFunction.java | 4 +-
.../apache/doris/catalog/AzureResourceTest.java | 55 +
.../java/org/apache/doris/catalog/ColumnTest.java | 9 +-
.../org/apache/doris/catalog/OlapTableTest.java | 132 ++
.../doris/cloud/catalog/CloudPartitionTest.java | 10 +
.../cloud/system/CloudSystemInfoServiceTest.java | 30 +-
.../org/apache/doris/common/Log4jConfigTest.java | 76 ++
.../doris/datasource/FileQueryScanNodeTest.java | 91 ++
.../apache/doris/datasource/FileSplitterTest.java | 216 +++
.../datasource/hive/source/HiveScanNodeTest.java | 89 ++
.../iceberg/IcebergMetadataOpsValidationTest.java | 180 +++
.../iceberg/source/IcebergScanNodeTest.java | 73 ++
.../datasource/jdbc/source/JdbcScanNodeTest.java | 133 ++
.../paimon/source/PaimonScanNodeTest.java | 46 +-
.../property/storage/AzurePropertiesTest.java | 78 ++
.../property/storage/AzurePropertyUtilsTest.java | 46 +-
.../property/storage/COSPropertiesTest.java | 4 +
.../property/storage/OBSPropertyTest.java | 4 +
.../property/storage/OSSPropertiesTest.java | 4 +
.../property/storage/OzonePropertiesTest.java | 183 +++
.../property/storage/S3PropertiesTest.java | 25 +
.../tvf/source/MetadataScanNodeTest.java | 7 +-
.../datasource/tvf/source/TVFScanNodeTest.java | 60 +
.../privilege/AccessControllerManagerTest.java | 174 +++
.../translator/PhysicalPlanTranslatorTest.java | 2 +-
.../doris/nereids/parser/SetPasswordParseTest.java | 128 ++
.../postprocess/CommonSubExpressionTest.java | 50 +
.../postprocess/MergeProjectPostProcessTest.java | 2 +-
.../PushDownFilterThroughProjectTest.java | 4 +-
.../nereids/rules/expression/FoldConstantTest.java | 13 +
.../SimplifyTimeFieldFromUnixtimeTest.java | 86 ++
.../functions/scalar/SearchDslParserTest.java | 370 +++++-
.../doris/nereids/trees/plans/PlanEqualsTest.java | 6 +-
.../plans/commands/ShowFrontendsCommandTest.java | 62 +-
.../doris/planner/FederationBackendPolicyTest.java | 4 +-
.../doris/planner/QueryCacheNormalizerTest.java | 1 +
.../org/apache/doris/qe/HmsQueryCacheTest.java | 3 +-
.../org/apache/doris/qe/OlapQueryCacheTest.java | 5 +-
.../apache/doris/system/SystemInfoServiceTest.java | 12 +-
.../connection/PostgresReplicationConnection.java | 932 +++++++++++++
.../reader/postgres/PostgresSourceReader.java | 12 +-
gensrc/proto/cloud.proto | 5 +-
gensrc/proto/internal_service.proto | 2 +
gensrc/thrift/Descriptors.thrift | 5 +-
gensrc/thrift/FrontendService.thrift | 15 +
gensrc/thrift/PlanNodes.thrift | 7 +
.../data/alter_p0/test_alter_column_char.out | 22 +
.../ann_range_search_nullable_literal.out | 54 +
.../data/datatype_p0/date/test_from_unixtime.out | 70 +
.../basic-elements/data-types/map-md.out | 4 +
.../data/export_p2/test_export_max_file_size.out | 1105 ++--------------
.../hive/test_hive_compress_type.out | 572 --------
.../action/test_iceberg_expire_snapshots.out | 10 +
.../iceberg/iceberg_schema_change_ddl.out | 28 +-
.../jdbc/test_pg_jdbc_catalog.out | 33 +-
.../jdbc/test_sqlserver_jdbc_catalog.out | 26 +-
.../analyzer/test_custom_analyzer.out | 9 +
.../test_bm25_score_range_filter.out | 33 +
.../cdc/test_streaming_postgres_job_partition.out | 10 +
.../datetime_functions/test_add_sub_union_type.out | 810 ++++++++++++
.../datetime_functions/test_date_function.out | 26 +-
.../spatial_functions/test_gis_function.out | 225 ++++
.../point_query_p0/test_point_query_timezone.out | 15 +
.../join/test_cte_exists/test_cte_exists.out | 44 +
.../array_functions/test_array_functions.out | 10 +
.../test_short_circuit_evaluation.out | 7 +
.../test_dateadd_with_other_timeunit.out | 97 ++
.../string_functions/test_previous_day.out | 185 +++
.../test_string_function_regexp.out | 45 +
.../data/search/test_search_dsl_operators.out | 45 +
regression-test/data/search/test_search_escape.out | 9 -
.../test_partial_update_multi_stmt.out | 25 +
.../variant_p0/test_variant_cast_strict_mode.out | 19 +
.../suites/account_p0/test_set_password.groovy | 69 +
.../suites/alter_p0/test_alter_column_char.groovy | 57 +
.../ann_range_search_nullable_literal.groovy | 237 ++++
.../auth_call/test_dml_delete_table_auth.groovy | 81 +-
.../test_modify_distribution_buckets.groovy | 474 +++++++
...test_cloud_alter_disable_auto_compaction.groovy | 193 +++
.../different_serialize/different_serialize.groovy | 12 +-
.../cloud_p0/multi_cluster/test_auto_start.groovy | 53 +
.../datatype_p0/date/test_from_unixtime.groovy | 97 +-
.../basic-elements/data-types/map-md.groovy | 24 +-
.../sql-functions/doc_date_functions_test.groovy | 4 +-
.../export_p2/test_export_max_file_size.groovy | 57 +-
.../hive/test_hive_compress_type.groovy | 25 +-
.../hive/test_orc_lazy_mat_profile.groovy | 310 +++++
.../hive/test_parquet_lazy_mat_profile.groovy | 604 +++++++++
.../hive/write/test_hive_ctas_to_doris.groovy | 2 +
.../action/test_iceberg_execute_actions.groovy | 92 +-
.../action/test_iceberg_expire_snapshots.groovy | 299 +++++
.../iceberg_branch_retention_and_snapshot.groovy | 18 +-
.../iceberg/iceberg_schema_change_ddl.groovy | 3 +-
...test_iceberg_schema_change_complex_types.groovy | 232 ++++
.../iceberg/test_iceberg_sys_table.groovy | 29 +-
.../jdbc/test_pg_jdbc_catalog.groovy | 10 +-
.../jdbc/test_sqlserver_jdbc_catalog.groovy | 24 +
.../tvf/test_frontends_disks_tvf.groovy | 13 +
.../tvf/test_frontends_tvf.groovy | 26 +-
.../hive/test_hive_translation_insert_only.groovy | 7 +-
.../hive/test_orc_merge_io_input_streams.groovy | 17 +-
.../hive/test_parquet_complex_cross_page.groovy | 9 +-
.../test_ordered_compaction_num_seg_rows.groovy | 3 +-
.../analyzer/test_custom_analyzer.groovy | 73 +-
.../inverted_index_p0/test_bm25_score.groovy | 6 +-
.../test_bm25_score_range_filter.groovy | 159 +++
.../cdc/test_streaming_postgres_job.groovy | 8 +-
.../test_streaming_postgres_job_partition.groovy | 178 +++
.../cdc/test_streaming_postgres_job_priv.groovy | 4 +-
.../test_routine_load_adaptive_param.groovy | 14 +-
.../test_routine_load_timeout_value.groovy | 6 +
.../stream_load/test_group_commit_redirect.groovy | 4 +-
.../test_json_lz4_decompress_progress.groovy | 84 ++
.../load_p0/stream_load/test_sink_tolerate.groovy | 39 +
.../nereids_p0/cache/mtmv_with_sql_cache.groovy | 999 ++++++++++++++
.../nereids_p0/cache/mv_with_sql_cache.groovy | 272 ++++
.../cache/parse_sql_from_sql_cache.groovy | 31 +
.../costbasedrewrite_producer.groovy | 43 +-
.../group_concat/test_group_concat.groovy | 28 +
.../test_add_sub_union_type.groovy | 645 +++++++++
.../datetime_functions/test_date_function.groovy | 23 +
.../spatial_functions/test_gis_function.groovy | 111 ++
.../test_point_query_timezone.groovy | 71 +
.../suites/query_p0/cache/query_cache.groovy | 2 +
.../query_p0/cache/query_cache_with_context.groovy | 65 +
.../join/test_cte_exists/test_cte_exists.groovy | 78 ++
.../array_functions/test_array_functions.groovy | 36 +
.../test_short_circuit_evaluation.groovy | 9 +
.../datetime_functions/test_date_floor_ceil.groovy | 38 +
.../datetime_functions/test_date_function.groovy | 6 -
.../test_dateadd_with_other_timeunit.groovy | 125 +-
.../string_functions/test_previous_day.groovy | 127 ++
.../test_string_function_regexp.groovy | 18 +
.../test_width_bucket_function.groovy | 6 +
.../search/test_search_boundary_cases.groovy | 40 +-
.../suites/search/test_search_dsl_operators.groovy | 231 ++++
.../suites/search/test_search_escape.groovy | 40 +-
.../search/test_search_function.groovy.backup | 261 ++++
.../search/test_search_null_regression.groovy | 24 +-
.../search/test_search_null_semantics.groovy | 16 +-
.../search/test_search_vs_match_consistency.groovy | 30 +-
.../test_partial_update_multi_stmt.groovy | 168 +++
.../test_variant_cast_strict_mode.groovy | 129 ++
thirdparty/download-thirdparty.sh | 13 +
thirdparty/patches/libhdfs3-v2.3.9-hostname.patch | 74 ++
532 files changed, 28097 insertions(+), 5495 deletions(-)
delete mode 100644 be/src/olap/wrapper_field.cpp
delete mode 100644 be/src/olap/wrapper_field.h
create mode 100644 be/src/vec/columns/column_execute_util.h
create mode 100644 be/test/common/config_on_update_test.cpp
create mode 100644 be/test/common/logconfig_test.cpp
create mode 100644
be/test/vec/columns/column_check_const_only_in_top_level_test.cpp
create mode 100644 be/test/vec/columns/column_execute_util_test.cpp
create mode 100644 be/test/vec/exprs/score_runtime_test.cpp
create mode 100644
fe/be-java-extensions/java-common/src/main/resources/log4j2.xml
rename
fe/{fe-core/src/main/java/org/apache/doris/datasource/property/constants =>
fe-common/src/main/java/org/apache/doris/common/maxcompute}/MCProperties.java
(90%)
create mode 100644
fe/fe-common/src/main/java/org/apache/doris/common/maxcompute/MCUtils.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudFEVersionSynchronizer.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudSyncVersionDaemon.java
copy
fe/{be-java-extensions/java-common/src/main/java/org/apache/doris/common/jni/utils/Log4jOutputStream.java
=>
fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonRestExternalCatalog.java}
(55%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/storage/OzoneProperties.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/rules/SimplifyTimeFieldFromUnixtime.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/DayHour.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/DayHourSub.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/DayMicrosecond.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/DayMicrosecondAdd.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/DayMicrosecondSub.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/DayMinute.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/DayMinuteAdd.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/DayMinuteSub.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/DaySecond.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/DaySecondSub.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{WidthBucket.java
=> HourFromUnixtime.java} (51%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/HourMicrosecond.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/HourMicrosecondAdd.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/HourMicrosecondSub.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/HourMinute.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/HourMinuteAdd.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/HourMinuteSub.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/HourSecond.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/HourSecondAdd.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/HourSecondSub.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/MicrosecondFromUnixtime.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{WidthBucket.java
=> MinuteFromUnixtime.java} (51%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/MinuteMicrosecond.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/MinuteMicrosecondAdd.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/MinuteMicrosecondSub.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/MinuteSecond.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/MinuteSecondSub.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/PreviousDay.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{WidthBucket.java
=> SecondFromUnixtime.java} (51%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/SecondMicrosecond.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/SecondMicrosecondSub.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/StDistance.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/StGeometryType.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/StLength.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/YearMonth.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/YearMonthAdd.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/YearMonthSub.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/ScoreRangeInfo.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/ScanContext.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/Log4jConfigTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/FileQueryScanNodeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/FileSplitterTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/hive/source/HiveScanNodeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/iceberg/IcebergMetadataOpsValidationTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/iceberg/source/IcebergScanNodeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/storage/OzonePropertiesTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/tvf/source/TVFScanNodeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mysql/privilege/AccessControllerManagerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/parser/SetPasswordParseTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/expression/SimplifyTimeFieldFromUnixtimeTest.java
create mode 100644
fs_brokers/cdc_client/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java
create mode 100644 regression-test/data/alter_p0/test_alter_column_char.out
create mode 100644
regression-test/data/ann_index_p0/ann_range_search_nullable_literal.out
create mode 100644
regression-test/data/external_table_p0/iceberg/action/test_iceberg_expire_snapshots.out
create mode 100644
regression-test/data/inverted_index_p0/test_bm25_score_range_filter.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_postgres_job_partition.out
create mode 100644
regression-test/data/nereids_p0/sql_functions/datetime_functions/test_add_sub_union_type.out
create mode 100644
regression-test/data/point_query_p0/test_point_query_timezone.out
create mode 100644
regression-test/data/query_p0/join/test_cte_exists/test_cte_exists.out
create mode 100644
regression-test/data/query_p0/sql_functions/string_functions/test_previous_day.out
create mode 100644 regression-test/data/search/test_search_dsl_operators.out
create mode 100644
regression-test/data/unique_with_mow_p0/partial_update/test_partial_update_multi_stmt.out
create mode 100644
regression-test/data/variant_p0/test_variant_cast_strict_mode.out
create mode 100644 regression-test/suites/account_p0/test_set_password.groovy
create mode 100644
regression-test/suites/alter_p0/test_alter_column_char.groovy
create mode 100644
regression-test/suites/ann_index_p0/ann_range_search_nullable_literal.groovy
create mode 100644
regression-test/suites/autobucket/test_modify_distribution_buckets.groovy
create mode 100644
regression-test/suites/cloud_p0/compaction/test_cloud_alter_disable_auto_compaction.groovy
create mode 100644
regression-test/suites/external_table_p0/hive/test_orc_lazy_mat_profile.groovy
create mode 100644
regression-test/suites/external_table_p0/hive/test_parquet_lazy_mat_profile.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/action/test_iceberg_expire_snapshots.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/test_iceberg_schema_change_complex_types.groovy
create mode 100644
regression-test/suites/inverted_index_p0/test_bm25_score_range_filter.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_partition.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_json_lz4_decompress_progress.groovy
create mode 100644
regression-test/suites/nereids_p0/cache/mtmv_with_sql_cache.groovy
create mode 100644
regression-test/suites/nereids_p0/cache/mv_with_sql_cache.groovy
rename
fe/be-java-extensions/java-common/src/main/java/org/apache/doris/common/jni/utils/Log4jOutputStream.java
=>
regression-test/suites/nereids_p0/cte/costbasedrewrite_producer/costbasedrewrite_producer.groovy
(55%)
create mode 100644
regression-test/suites/nereids_p0/sql_functions/datetime_functions/test_add_sub_union_type.groovy
create mode 100644
regression-test/suites/point_query_p0/test_point_query_timezone.groovy
create mode 100644
regression-test/suites/query_p0/cache/query_cache_with_context.groovy
create mode 100644
regression-test/suites/query_p0/join/test_cte_exists/test_cte_exists.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/string_functions/test_previous_day.groovy
create mode 100644
regression-test/suites/search/test_search_dsl_operators.groovy
create mode 100644
regression-test/suites/search/test_search_function.groovy.backup
create mode 100644
regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_multi_stmt.groovy
create mode 100644
regression-test/suites/variant_p0/test_variant_cast_strict_mode.groovy
create mode 100644 thirdparty/patches/libhdfs3-v2.3.9-hostname.patch
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
