This is an automated email from the ASF dual-hosted git repository.
morningman pushed a change to branch branch-catalog-spi
in repository https://gitbox.apache.org/repos/asf/doris.git
omit e5959e1b53d [refactor](catalog) P3b: consolidate kerberos
authentication into fe-kerberos (#64655)
omit d59ed2f96d9 [refactor](catalog) P5 paimon: remove legacy subsystem
from fe-core + make fe-core paimon-SDK-free (T29) (#64653)
omit 38e7140ce56 [refactor](catalog) P5 paimon: migrate to catalog SPI +
cutover (#64446) (#64446)
omit e9c5b3e70ce update P5 handoff and fix compile issue
omit 73832991962 [refactor](connector) P4 maxcompute: remove legacy
subsystem from fe-core + make fe-core odps-free (T07-T09) (#64300)
omit bfff78d3ab0 [feat](connector) P3 hudi connector hardening + test
baseline + dispatch design (hybrid, T02-T08) (#64143)
omit 508e7feaa56 [feat](connector) P2 migrate trino-connector to catalog
SPI (T01-T13) (#64096)
omit 0e2865b2d7c [P1-T03-T05] route plugin-driven scans first in nereids
translator (#63641)
omit aa2c2871967 [feat](connector) P0 SPI baseline + DDL/Partition + import
gate (T03-T27) (#63582)
omit d8ff6ba86ac [doc](connector) add project tracking system for catalog
SPI migration
add 28c17f83589 [fix](regression) fix regression test_hive_ctas_to_doris
failure (#64553)
add 800b6a100cf [Fix](test) Allow bitmap base64 serialization variants
(#64505)
add 7bef21c5be6 [fix](test) fix regression test eliminate_inner (#64457)
add e025050cdb0 [fix](streaming-job) streaming CDC reliability fixes
(scheduling latch, fetch-meta reason, PG db name, flaky case) (#64310)
add 7e8f1b21ea8 [fix](variant) Preserve json object when casting jsonb to
variant (#63792)
add 35089583cf8 [fix](variant) Handle truncated sparse path stats when
reading variant (#64205)
add f9e8d698327 [fix](cloud) Fix some docker case due to open
skip_writing_empty_rowset_metadata (#64565)
add 6e368807cf8 [test](mv) Add MV residual compensation coverage (#64051)
add 954e717b1bf [fix](audit) record per-query SET_VAR hint session
variables in audit log (#64569)
add 4fec15443ab [fix](topn) Skip TopN lazy materialization when
light_schema_change=false (#64441)
add 6879d610659 [fix](be) Normalize v1 date string cast result (#64575)
add a2eb4d6eed6 [fix](NestedColumnPruning) collect full-access paths for
array columns unreferenced in lambda body (#64436)
add 08cd09f4ff5 [fix](stream_load) Fix stream load IPv6 host parsing
(#64147)
add ab8f6572aea [chore](ci) declare least-privilege permissions on
clang-format and title-checker workflows (#63573)
add 0141aa20221 [feature](be) Add BE stack trace HTTP API (#64454)
add 6a7fc862723 [fix](be) Preserve nested paths for lazy rowid fetch
(#64242)
add f7b7d9ce005 [feature](runtime-filter) Support bloom pruning for list
partitions (#64318)
add 2915bdb6230 [fix](nereids) allow constant output column not in GROUP
BY under only_full_group_by (#64458)
add fac13b82353 [fix](audit) deflake test_audit_log_hint_session_context
(#64617)
add aeb76c4a636 [fix](regression) Use explicit size call in nested type
plugin (#64610)
add d6747286c9c [fix](scan) read delete-condition columns in full to avoid
leaking deleted rows (#64601)
add 6a268dcaa08 [fix](cloud) Recycle empty rowsets without resource id
(#64630)
add a0907700fcb [fix](NestedColumnPruning): visit key/value/entry args in
visitMapContainsKey/Value/Entry (#64440)
add 6cd402ba448 [fix](NestedColumnPruning) Rewrite the
NestedColumnPruning meta-path handling to properly eliminate redundant
NULL/OFFSET access paths and prevent unsafe BE reader mode combinations.
(#64535)
add 67651ae0229 [chore](jsonb) Remove unused code in function_jsonb
(#64129)
add 87023f54a80 [fix](be) Stabilize conjunct cost ordering (#64637)
add 88991dc3386 [improvement](ci) Refine Codex review goal completion
prompt (#64658)
add 4337c56e98c [fix](streamingjob) Cap debezium ChangeEventQueue with a
heap-adaptive byte limit to avoid OOM (#64511)
add fdaa0b1d7b3 [fix](retention) Limit param count to 32 to avoid BE heap
overflow (#64521)
add 6d28423c726 [fix](process list) return unexpected result in FULL mode
(#64631)
add 664915e4e9e [fix](regression-test) pin time_zone in
test_nested_types_insert_into_with_s3 (#64659)
add 6d2417b0b7f [fix](fe) Show warm-up timestamps with date (#64606)
add 403a466421b [feature](eager-agg) Bilateral push-down for eager
aggregation (#63690)
add 5f0d964d79d [fix](regression-test) fix two muted test cases (Groovy
property access + flaky SHOW PROCESSLIST) (#63645)
add 90db340515e [improvement](CI) Support centralized memory consolidation
and reuse (#64665)
add efc0a09769f [fix](be) Fix duplicate symbol __lsan_ignore_object when
build be ut in LSAN (#64164)
add 07ad6482dd4 [fix](file-cache) Make sync clear use safe removal (#64578)
add 0f88df67964 [fix](test) fix flaky test_time_series_compaction_level2
(#64663)
add da82d6a3c14 [fix](cloud-compaction) prevent EMPTY_CUMULATIVE /
BASE-CUMU races on the same tablet (#64619)
add ea6445bbfce [fix](regression-test) fix stale nested-type assertions in
two_level/three_level_nestedtypes_with_s3data (#64706)
add bac218e24af [fix](load) respect profile level for writer details
(#64620)
add 17867b8d184 [opt](serde)Build Arrow serde error context lazily.
(#64660)
add 7b90b8aed45 [fix](outfile)Preserve DateTimeV2 scale in OUTFILE CSV.
(#64344)
add 5874eff8175 [fix](subquery) eliminate null aware by mistake (#64639)
add d9d22ed81b3 [improve](streaming-job) make from-to streaming task
timeout progress-aware (#64301)
add c852e608302 [improve](streaming-job) admit multiple splits per
scheduler tick to speed up many-table snapshot (#64566)
add f3216d8c1c6 [fix](cases) remove duplicate cases and useless out check
file (#64687)
add c0c5a8a6ba2 [test](regression) drop unsupported use_path_style=true in
test_s3_tvf (#64562)
add c254c020bde [test](be) Improve core BE unit coverage (#64450)
add f025cbd79c5 [opt](sum0) update sum0 comments (#64669)
add 8c0ca8e268e [refactor](local shuffle) Move local exchange planning
from BE to FE (#63366)
add 2b4e9061c7b [refine](function) avoid unnecessary COW column clones
(#64627)
add 3370aa003ff [Opt](reservoir-sampler) Optimize percentile_reservoir
batch aggregation (#64593)
add 4b8573234e0 [fix](fe) Merge TopN with child prefix order keys (#64685)
add cebf71c12e5 [fix](be) Fix concat_ws nullable array handling (#64703)
add 80b4aa80a23 [fix](test) Stabilize test_sql_block_rule_status BLOCKS
assertion (#64668)
add 328ad6ace17 [build](Variant) Show Variant NestedGroup feature flag
(#64727)
add 8dde6b6cc01 [fix](iceberg)fix iceberg write special partition error.
(#64225) (#64339)
add 2e72b96abfd [fix](load) replace tablet writer close polling with event
wakeup (#64221)
add 9d55a551627 [improve](streaming-job) Bind the incremental phase to a
fixed BE and reuse the cdc reader (#64423)
add d293e8e44af [feature](be) Support zstd stream load compression (#64711)
add 30d27ca95de [fix](be) Protect tablet writer map lookup in load channel
(#64604)
add cb1d65f217f [fix](regression) Increase variant export load timeout
(#64733)
add 9816a5a20b6 [fix](be) Check block column and type pointers (#64721)
add 04cae614aaa [feat](Variant) Support NestedGroup public config (#64680)
add e5f3badd010 [fix](job) lock routine load task renew on submit failure
(#64731)
add 7b0d4ffa079 [feat](s3) support S3 storage vault credentials provider
without role ARN (#64766)
add bacfb0fe377 [perf](s3) push down expandable S3 glob prefixes (#64684)
add 0f7917f1007 [build](variant) Support release extra module hooks
(#64737)
add 6bf4327a7a5 [fix](maxcompute) Estimate write block size from Arrow
buffers, not per-row serialization (#64612)
add 6382bb24b9e [feature](fe) Add connection max metrics (#64742)
add 5355fbe835a [test](jdbc) Add SQL Server bit/boolean predicate pushdown
regression test (#64756)
add 893e5a3a2eb [fix](fe) Avoid blocking external meta cache refresh on
slow miss load (#64705)
add c7f355922c1 [Fix](thirdparty) Unify arrow cpp standard with be (#64390)
add e5da615f9e0 [refine](column) Remove pointer access from column element
view (#64724)
add 86ac986053c [fix](function) Return null for invalid base64 input
length (#64788)
add fe5192f7090 [fix](regression) Fix array string insert error assertion
(#64746)
add 1097d51a86d [Enhance](func) Delete useless code of split_by_char
(#64801)
add 6d4b87692b8 [test](be) Migrate variant index storage debugpoint tests
(#64348)
add 6a357f22254 [fix](window) only allow 1 argument in count distinct in
window function (#64783)
add ad269d4dd27 [opt](column) avoid redundant COW column clones (#64735)
add d48744d072d [fix](test)fix out file of test_leading (#64605)
add 556586ce729 [fix](using join) Fix USING JOIN merge key for RIGHT/FULL
OUTER and RIGHT SEMI joins (#64718)
add a1ac4dbed75 [fix](hive) Preserve empty text records (#64671)
add dee9cfb7322 [improvement](fe) Infer set operator distinct by NDV
(#64618)
add 6e4d434e41f [fix](fe) Enable profiles for computed DML commands
(#64551)
add 8fd2c1bd805 [fix](streaming-job) initialize CDC reader at CREATE JOB
and propagate remote errors (#64728)
add 87d6090a758 [fix](jdbc) order composite primary key columns by KEY_SEQ
(#64740)
add 48d9e57b5e5 [fix](cloud) Use bthread-aware shared mutex for tablet
header lock (#64574)
add a786cba9824 [fix](load) only load source scanners update load counters
(#63781)
add 38df92bc209 [fix](scan) Avoid misleading "storage reader" wrapper for
data/expression errors (#64755)
add afc3c35e18c [fix](cloud) make S3 rate limiter config take effect
dynamically in cloud mode (#64554)
add ed446e14d30 [fix](test) skip force_olap_table_replication_num check in
cloud mode for show replica dist (#64374)
add 94f6a162ada [fix](test) Fix mow_insert_with_partition_drop polluting
neighbor suites (#64376)
add ba778aa4be4 [fix](cloud) Persist update time for sub txn commit
(#64739)
add 471def6539e [fix](fe) Fix IS TRUE/ IS FALSE predicate null semantics
(#64696)
add 0a1a72ec2ac [fix](streaming-job) cdc client MySQL TIME range fix with
type-consistency and GTID guards (#64741)
add 3cd43b65e5a [improvement](catalog) narrow MaterializedIndex addTablet
sync scope (#64478)
add 248d3c1ae05 [fix](function) Validate array_sort lambda arity (#64825)
add a03283ae803 [fix](filecache) Limit LRU recorder shadow queue size
(#64798)
add d48a61d2adb [fix](fe) Clear warm-up error message after successful
retry (#64813)
add 3226e0c28ac [fix](regression-test) stabilize nested type S3
expectations (#64822)
add e8d1b5e5ed0 [fix](analyzer) Normalize aggregate order by pushdown
(#64787)
add a877701d0b1 [feature](aggregate) Add map aggregate functions (#64774)
add 932f7898e65 [improvement](runtime-filter) Limit broadcast runtime
filter producers (#64683)
add 896bf298209 [fix](array function) Support boolean cast for array first
and last (#64847)
add bb628eb8ca1 [fix](arrow-flight) Harden split source error path to
avoid BE crash on external table scan (#64797)
add e4812d1ce85 [fix](be) Fix nth_value for upper bounded windows (#64864)
add 8dca6c89bbb [fix](function) Align constant folding with BE results
(#64881)
add 2893331370b [fix](regression) fix one_level_nestedtypes_with_s3data
(#64832)
add 2266f92cb9d [fix](hive) Key Hive partition cache by name (#64867)
add 7bc98f696f1 [fix](nereids) partition topn opt requires chosen window
func partition key to be a subset of co-located ones (#64764)
add 588189559ea [doc](connector) add project tracking system for catalog
SPI migration
add 7706bc0313d [feat](connector) P0 SPI baseline + DDL/Partition + import
gate (T03-T27) (#63582)
add 177aa5a66b2 [P1-T03-T05] route plugin-driven scans first in nereids
translator (#63641)
add 36eb7515225 [feat](connector) P2 migrate trino-connector to catalog
SPI (T01-T13) (#64096)
add 11d36159eee [feat](connector) P3 hudi connector hardening + test
baseline + dispatch design (hybrid, T02-T08) (#64143)
add 3fb7f392a93 [refactor](connector) P4 maxcompute: remove legacy
subsystem from fe-core + make fe-core odps-free (T07-T09) (#64300)
add 95911521a5a update P5 handoff and fix compile issue
add f38da2ee938 [refactor](catalog) P5 paimon: migrate to catalog SPI +
cutover (#64446) (#64446)
add 0214560d5f3 [refactor](catalog) P5 paimon: remove legacy subsystem
from fe-core + make fe-core paimon-SDK-free (T29) (#64653)
add 52822b098c4 [refactor](catalog) P3b: consolidate kerberos
authentication into fe-kerberos (#64655)
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 (e5959e1b53d)
\
N -- N -- N refs/heads/branch-catalog-spi (52822b098c4)
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:
.claude/skills/code-review/SKILL.md | 10 +-
.github/workflows/clang-format.yml | 5 +
.github/workflows/code-review-runner.yml | 188 +-
.github/workflows/title-checker.yml | 4 +
be/CMakeLists.txt | 21 +-
be/src/cloud/cloud_base_compaction.cpp | 2 +-
be/src/cloud/cloud_cumulative_compaction.cpp | 2 +-
be/src/cloud/cloud_full_compaction.cpp | 2 +-
be/src/cloud/cloud_meta_mgr.cpp | 4 +-
be/src/cloud/cloud_meta_mgr.h | 2 +-
be/src/cloud/cloud_storage_engine.cpp | 9 +
be/src/cloud/cloud_tablet.cpp | 51 +-
be/src/cloud/cloud_tablet.h | 16 +-
be/src/common/config.cpp | 6 +-
be/src/common/phdr_cache.cpp | 10 +-
be/src/common/stack_trace.cpp | 30 +-
be/src/core/arena.h | 2 +-
be/src/core/arena_with_free_lists.h | 103 -
be/src/core/block/block.cpp | 25 +-
be/src/core/block/block.h | 2 +
be/src/core/column/column.cpp | 37 +-
be/src/core/column/column.h | 7 +-
be/src/core/column/column_array.h | 7 +-
be/src/core/column/column_const.h | 6 +-
be/src/core/column/column_execute_util.h | 18 +-
be/src/core/column/column_map.h | 8 +-
be/src/core/column/column_nullable.h | 7 +-
be/src/core/column/column_struct.cpp | 8 +-
be/src/core/column/column_struct.h | 3 +-
be/src/core/column/column_variant.cpp | 17 +-
be/src/core/column/column_variant.h | 3 +-
be/src/core/data_type/nested_utils.cpp | 66 -
.../core/data_type_serde/data_type_array_serde.cpp | 6 +-
.../data_type_serde/data_type_bitmap_serde.cpp | 5 +-
.../data_type_date_or_datetime_serde.cpp | 5 +-
.../data_type_serde/data_type_datetimev2_serde.cpp | 10 +-
.../data_type_serde/data_type_datev2_serde.cpp | 5 +-
.../data_type_serde/data_type_decimal_serde.cpp | 30 +-
.../core/data_type_serde/data_type_hll_serde.cpp | 5 +-
.../core/data_type_serde/data_type_ipv4_serde.cpp | 2 +-
.../core/data_type_serde/data_type_ipv6_serde.cpp | 5 +-
.../core/data_type_serde/data_type_jsonb_serde.cpp | 5 +-
.../core/data_type_serde/data_type_map_serde.cpp | 9 +-
.../data_type_serde/data_type_number_serde.cpp | 20 +-
.../data_type_quantilestate_serde.h | 5 +-
be/src/core/data_type_serde/data_type_serde.h | 7 +-
.../data_type_serde/data_type_string_serde.cpp | 5 +-
.../data_type_serde/data_type_struct_serde.cpp | 6 +-
.../data_type_timestamptz_serde.cpp | 8 +-
.../data_type_serde/data_type_varbinary_serde.cpp | 5 +-
.../data_type_serde/data_type_variant_serde.cpp | 5 +-
be/src/core/value/large_int_value.cpp | 5 -
be/src/core/value/large_int_value.h | 2 -
be/src/exec/common/util.hpp | 23 +-
be/src/exec/common/variant_util.cpp | 44 +-
.../exec/exchange/local_exchange_sink_operator.cpp | 75 +-
.../exec/exchange/local_exchange_sink_operator.h | 35 +-
.../exchange/local_exchange_source_operator.cpp | 5 +-
.../exec/exchange/local_exchange_source_operator.h | 40 +-
be/src/exec/exchange/local_exchanger.h | 42 +-
be/src/exec/operator/aggregation_sink_operator.h | 8 +-
be/src/exec/operator/analytic_sink_operator.h | 8 +-
be/src/exec/operator/assert_num_rows_operator.h | 2 +-
.../operator/bucketed_aggregation_sink_operator.h | 2 +-
.../distinct_streaming_aggregation_operator.h | 10 +-
be/src/exec/operator/exchange_source_operator.h | 8 +-
be/src/exec/operator/hashjoin_build_sink.h | 12 +-
be/src/exec/operator/hashjoin_probe_operator.h | 14 +-
.../operator/multi_cast_data_stream_source.cpp | 2 +-
.../operator/nested_loop_join_build_operator.h | 6 +-
.../operator/nested_loop_join_probe_operator.h | 4 +-
be/src/exec/operator/operator.cpp | 15 +-
be/src/exec/operator/operator.h | 9 +-
.../exec/operator/partition_sort_sink_operator.h | 5 +-
.../partitioned_hash_join_probe_operator.cpp | 2 -
.../partitioned_hash_join_probe_operator.h | 14 +-
.../operator/partitioned_hash_join_sink_operator.h | 6 +-
.../exec/operator/rec_cte_anchor_sink_operator.h | 2 +-
be/src/exec/operator/rec_cte_sink_operator.h | 2 +-
be/src/exec/operator/rec_cte_source_operator.h | 2 +-
be/src/exec/operator/scan_operator.cpp | 3 +-
be/src/exec/operator/scan_operator.h | 4 +-
be/src/exec/operator/set_probe_sink_operator.h | 6 +-
be/src/exec/operator/set_sink_operator.h | 6 +-
be/src/exec/operator/set_source_operator.h | 4 +-
be/src/exec/operator/sort_sink_operator.h | 10 +-
.../exec/operator/streaming_aggregation_operator.h | 6 +-
be/src/exec/operator/table_function_operator.h | 2 +-
be/src/exec/operator/union_sink_operator.h | 5 +-
be/src/exec/operator/union_source_operator.h | 4 +-
be/src/exec/pipeline/dependency.h | 51 +-
be/src/exec/pipeline/pipeline.cpp | 6 +-
be/src/exec/pipeline/pipeline.h | 15 +-
be/src/exec/pipeline/pipeline_fragment_context.cpp | 339 +-
be/src/exec/pipeline/pipeline_fragment_context.h | 30 +-
be/src/exec/rowid_fetcher.cpp | 24 +
.../runtime_filter_partition_pruner.cpp | 86 +-
.../runtime_filter_partition_pruner.h | 4 +
be/src/exec/scan/file_scanner.cpp | 13 +
be/src/exec/scan/file_scanner.h | 2 +
be/src/exec/scan/olap_scanner.cpp | 6 +-
be/src/exec/scan/scanner.cpp | 8 +-
be/src/exec/scan/scanner.h | 7 +
be/src/exec/scan/split_source_connector.cpp | 4 +-
be/src/exec/sink/load_stream_map_pool.cpp | 17 +-
be/src/exec/sink/load_stream_map_pool.h | 5 +
be/src/exec/sink/load_stream_stub.cpp | 32 +-
be/src/exec/sink/load_stream_stub.h | 36 +-
.../sink/writer/iceberg/iceberg_partition_path.cpp | 52 +
.../sink/writer/iceberg/iceberg_partition_path.h} | 16 +-
.../sink/writer/iceberg/viceberg_table_writer.cpp | 25 +-
.../sink/writer/maxcompute/vmc_table_writer.cpp | 2 +-
be/src/exec/sink/writer/vhive_table_writer.cpp | 22 +-
be/src/exec/sink/writer/vtablet_writer.cpp | 26 +-
be/src/exec/sink/writer/vtablet_writer.h | 13 +
be/src/exec/sink/writer/vtablet_writer_v2.cpp | 16 +-
.../aggregate_function_map_combinator.cpp | 478 +
.../aggregate/aggregate_function_map_combinator.h | 14 +-
.../aggregate_function_percentile_reservoir.h | 43 +-
.../exprs/aggregate/aggregate_function_retention.h | 13 +-
.../aggregate_function_simple_factory.cpp | 2 +
be/src/exprs/aggregate/aggregate_function_window.h | 9 +-
.../exprs/function/array/function_array_element.h | 5 +-
.../function/array/function_array_enumerate.cpp | 3 +-
.../array/function_array_enumerate_uniq.cpp | 5 +-
.../exprs/function/array/function_array_exists.cpp | 12 +-
.../exprs/function/array/function_array_sortby.cpp | 13 +-
.../cast/cast_to_date_or_datetime_impl.hpp | 2 +
be/src/exprs/function/cast/cast_to_variant.h | 4 +-
be/src/exprs/function/function.cpp | 2 +-
.../function_date_or_datetime_to_string.cpp | 6 +-
be/src/exprs/function/function_jsonb.cpp | 29 +-
be/src/exprs/function/function_nullables.cpp | 6 +-
be/src/exprs/function/function_string.cpp | 6 +
be/src/exprs/function/function_string_concat.h | 12 +
be/src/exprs/function/function_varbinary.cpp | 5 +
be/src/exprs/function/function_variant_element.cpp | 3 +-
.../exprs/lambda_function/varray_map_function.cpp | 18 +-
be/src/exprs/runtime_filter_expr.cpp | 2 +-
be/src/exprs/vcondition_expr.cpp | 3 +-
be/src/exprs/vexpr_context.cpp | 16 +-
be/src/exprs/vexpr_context.h | 3 +-
be/src/exprs/vtopn_pred.h | 2 +-
be/src/format/arrow/arrow_utils.cpp | 12 +-
be/src/format/csv/csv_reader.cpp | 18 +-
be/src/format/csv/csv_reader.h | 1 +
be/src/format/parquet/vparquet_group_reader.cpp | 2 +-
be/src/format/text/text_reader.cpp | 6 +
be/src/format/text/text_reader.h | 1 +
be/src/io/cache/block_file_cache.cpp | 154 +-
be/src/io/cache/block_file_cache.h | 12 +-
be/src/io/cache/block_file_cache_factory.cpp | 45 +-
be/src/io/cache/block_file_cache_factory.h | 2 +
be/src/io/cache/file_cache_common.h | 2 +
be/src/io/cache/fs_file_cache_storage.cpp | 4 +
be/src/io/cache/lru_queue_recorder.cpp | 121 +-
be/src/io/cache/lru_queue_recorder.h | 4 +
be/src/load/channel/tablets_channel.cpp | 22 +-
be/src/runtime/cdc_client_mgr.cpp | 5 +
be/src/runtime/exec_env_init.cpp | 11 +
be/src/runtime/runtime_state.h | 7 +-
.../service/http/action/be_thread_stack_action.cpp | 1215 ++
.../service/http/action/be_thread_stack_action.h | 43 +
be/src/service/http/action/file_cache_action.cpp | 24 +-
be/src/service/http/action/http_stream.cpp | 30 +-
be/src/service/http/action/stream_load.cpp | 8 +-
be/src/service/http_service.cpp | 5 +
be/src/storage/CMakeLists.txt | 8 +
be/src/storage/compaction/binlog_compaction.cpp | 2 +-
be/src/storage/compaction/compaction.cpp | 4 +-
.../cumulative_compaction_time_series_policy.cpp | 9 +-
be/src/storage/compaction/full_compaction.cpp | 2 +-
be/src/storage/predicate/column_predicate.h | 32 +-
be/src/storage/predicate/comparison_predicate.h | 28 +-
be/src/storage/predicate/in_list_predicate.h | 30 +-
be/src/storage/predicate/null_predicate.cpp | 8 +-
be/src/storage/rowset_builder.cpp | 2 +-
be/src/storage/schema_change/schema_change.cpp | 4 +-
be/src/storage/segment/column_reader.cpp | 1 -
be/src/storage/segment/segment.cpp | 1 +
.../segment/variant/nested_group_provider.cpp | 12 +-
.../segment/variant/variant_column_reader.cpp | 17 +-
be/src/storage/tablet/base_tablet.cpp | 4 +
be/src/storage/tablet/base_tablet.h | 9 +-
be/src/storage/tablet/tablet.cpp | 65 +-
be/src/storage/tablet/tablet.h | 9 +-
be/src/storage/tablet/tablet_manager.cpp | 2 +-
be/src/storage/tablet/tablet_reader.cpp | 27 +
be/src/storage/tablet/tablet_reader.h | 7 +
be/src/storage/task/engine_clone_task.cpp | 2 +-
be/src/storage/task/index_builder.cpp | 4 +-
be/src/util/bthread_shared_mutex.h | 125 +
be/src/util/debug/leak_annotations.h | 18 +-
be/src/util/load_util.cpp | 25 +
be/src/util/load_util.h | 5 +-
be/src/util/reservoir_sampler.h | 10 +-
be/src/util/s3_util.h | 3 +
be/src/util/thrift_server.cpp | 85 +-
be/test/CMakeLists.txt | 6 +
.../cloud/cloud_empty_rowset_compaction_test.cpp | 2 +-
be/test/cloud/cloud_meta_mgr_test.cpp | 28 +-
be/test/cloud/cloud_tablet_test.cpp | 2 +-
be/test/core/accurate_comparison_test.cpp | 45 +
be/test/core/column/column_filter_helper_test.cpp | 52 +
be/test/core/data_type/block_check_type.cpp | 20 +-
be/test/core/data_type/data_type_nothing_test.cpp | 67 +-
.../data_type_serde_bitmap_test.cpp | 11 +
.../data_type_serde_datetime_v2_test.cpp | 87 +
.../data_type_serde/data_type_serde_hll_test.cpp | 10 +
.../data_type_serde/data_type_serde_map_test.cpp | 6 +
.../data_type_serde_quantile_state_test.cpp | 73 +-
.../data_type_serde_struct_test.cpp | 6 +
.../data_type_serde_variant_test.cpp | 67 +
be/test/core/packed_int128_test.cpp | 71 +
.../core/value/large_int_value_test.cpp} | 43 +-
be/test/exec/common/schema_util_test.cpp | 95 +-
be/test/exec/operator/agg_operator_test.cpp | 16 +-
...istinct_streaming_aggregation_operator_test.cpp | 4 +-
.../exec/operator/streaming_agg_operator_test.cpp | 4 +-
be/test/exec/pipeline/local_exchanger_test.cpp | 15 +-
be/test/exec/pipeline/pipeline_test.cpp | 21 +-
.../runtime_filter_partition_pruner_test.cpp | 107 +
be/test/exec/sink/vtablet_writer_v2_test.cpp | 21 +
.../writer/iceberg/iceberg_partition_path_test.cpp | 40 +
.../aggregate/agg_percentile_reservoir_test.cpp | 96 +
.../exprs/aggregate/agg_window_nth_value_test.cpp | 81 +
be/test/exprs/aggregate/vec_retention_test.cpp | 17 +
be/test/exprs/function/cast/cast_to_date_test.cpp | 12 +
.../function/cast/function_variant_cast_test.cpp | 12 +-
be/test/exprs/function/function_is_null_test.cpp | 11 +-
be/test/exprs/function/function_string_test.cpp | 3 +
be/test/exprs/function/function_varbinary_test.cpp | 3 +
be/test/io/cache/block_file_cache_test.cpp | 185 +
.../io/cache/block_file_cache_test_meta_store.cpp | 40 +-
be/test/io/cache/cache_lru_dumper_test.cpp | 106 +
.../service/http/be_thread_stack_action_test.cpp | 437 +
be/test/service/http/file_cache_action_test.cpp | 10 +-
be/test/storage/index_storage_lifecycle_test.cpp | 516 +
.../storage/index_storage_schema_patch_test.cpp | 53 +
.../storage/segment/nested_group_provider_test.cpp | 20 +-
be/test/storage/tablet_reader_test.cpp | 131 +
.../index_storage/variant_path_index.jsonl | 2 +
.../index_storage_variant_compaction_read_test.cpp | 283 +
...ndex_storage_variant_compaction_schema_test.cpp | 208 +
.../index_storage_variant_debug_point_test.cpp | 210 +
...x_storage_variant_dynamic_path_pruning_test.cpp | 333 +
.../index_storage_variant_expr_pushdown_test.cpp | 471 +
...ex_storage_variant_field_pattern_index_test.cpp | 796 ++
...x_storage_variant_path_index_lifecycle_test.cpp | 527 +
...index_storage_variant_schema_evolution_test.cpp | 308 +
.../index_storage_variant_schema_patch_test.cpp | 86 +
.../index_storage_variant_sparse_stats_test.cpp | 353 +
.../variant/index_storage_variant_test_base.h | 136 +
.../variant_column_writer_reader_test.cpp | 14 +
.../variant_doc_mode_compaction_test.cpp | 0
.../variant_stats_calculator_test.cpp | 46 +-
.../{segment => variant}/variant_util_test.cpp | 0
be/test/testutil/index_storage_test_util.cpp | 1578 +++
be/test/testutil/index_storage_test_util.h | 346 +
be/test/util/bthread_shared_mutex_test.cpp | 264 +
be/test/util/load_util_test.cpp | 41 +
be/test/util/s3_util_test.cpp | 45 +
build.sh | 1 +
cloud/src/meta-service/meta_service_job.cpp | 90 +-
cloud/src/meta-service/meta_service_resource.cpp | 29 +-
cloud/src/meta-service/meta_service_txn.cpp | 7 +-
cloud/src/recycler/recycler.cpp | 14 +-
cloud/src/recycler/s3_accessor.cpp | 9 +-
cloud/test/meta_service_job_test.cpp | 215 +
cloud/test/meta_service_operation_log_test.cpp | 7 +
cloud/test/meta_service_test.cpp | 62 +-
cloud/test/recycler_test.cpp | 31 +
docker/runtime/doris-compose/Dockerfile | 3 +-
.../hive/scripts/data/regression/crdmm_data/run.sh | 7 +-
.../hive/scripts/data/regression/serde_prop/run.sh | 25 +
.../regression/serde_prop/some_serde_table.hql | 25 +-
.../doris/maxcompute/MaxComputeJniWriter.java | 184 +-
.../doris/maxcompute/MaxComputeJniWriterTest.java | 133 +
.../main/java/org/apache/doris/common/Config.java | 15 +
.../apache/doris/job/cdc/StreamingTaskStatus.java | 50 +
...eRecordRequest.java => TaskFailureRequest.java} | 36 +-
.../doris/job/cdc/request/WriteRecordRequest.java | 4 +
.../doris/catalog/BuiltinAggregateFunctions.java | 10 +
.../doris/catalog/BuiltinScalarFunctions.java | 2 -
.../java/org/apache/doris/catalog/EnvFactory.java | 16 +-
.../apache/doris/catalog/MaterializedIndex.java | 29 +-
.../org/apache/doris/cloud/CloudWarmUpJob.java | 14 +
.../org/apache/doris/cloud/JobWarmUpStats.java | 4 +-
.../doris/cloud/catalog/CloudEnvFactory.java | 4 +-
.../doris/common/proc/FrontendsProcNode.java | 16 +-
.../apache/doris/common/util/PropertyAnalyzer.java | 8 +-
.../doris/datasource/hive/HMSExternalTable.java | 26 +-
.../apache/doris/datasource/hive/HiveDlaTable.java | 23 +-
.../datasource/hive/HiveExternalMetaCache.java | 86 +-
.../datasource/jdbc/client/JdbcMySQLClient.java | 10 +-
.../doris/datasource/metacache/MetaCacheEntry.java | 129 +-
.../datasource/property/storage/S3Properties.java | 20 +-
.../org/apache/doris/httpv2/rest/LoadAction.java | 31 +-
.../doris/httpv2/rest/StreamingJobAction.java | 40 +-
.../org/apache/doris/job/common/FailureReason.java | 11 +-
.../insert/streaming/AbstractStreamingTask.java | 15 +-
.../streaming/PostgresResourceValidator.java | 17 +
.../insert/streaming/StreamingInsertJob.java | 141 +-
.../insert/streaming/StreamingMultiTblTask.java | 134 +-
.../org/apache/doris/job/manager/JobManager.java | 2 +-
.../doris/job/offset/SourceOffsetProvider.java | 8 +
.../job/offset/jdbc/JdbcSourceOffsetProvider.java | 140 +-
.../apache/doris/job/util/StreamingJobUtils.java | 18 +
.../load/routineload/RoutineLoadTaskScheduler.java | 42 +-
.../java/org/apache/doris/metric/MetricRepo.java | 74 +
.../org/apache/doris/mysql/privilege/Auth.java | 14 +
.../doris/mysql/privilege/UserPropertyMgr.java | 8 +
.../org/apache/doris/nereids/NereidsPlanner.java | 17 +-
.../glue/translator/PhysicalPlanTranslator.java | 80 +-
.../glue/translator/PlanTranslatorContext.java | 37 +
.../RuntimeFilterPartitionPruneClassifier.java | 7 +-
.../glue/translator/RuntimeFilterTranslator.java | 4 +-
.../doris/nereids/jobs/executor/Rewriter.java | 13 +-
.../nereids/jobs/rewrite/CostBasedRewriteJob.java | 3 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 16 +-
.../post/materialize/LazyMaterializeTopN.java | 11 +
.../post/materialize/MaterializeProbeVisitor.java | 20 +-
.../nereids/rules/analysis/BindExpression.java | 60 +-
.../nereids/rules/analysis/ExpressionAnalyzer.java | 23 +-
.../nereids/rules/analysis/NormalizeAggregate.java | 68 +-
.../nereids/rules/analysis/SubqueryToApply.java | 25 +-
.../rules/analysis/WindowFunctionChecker.java | 19 +-
.../rewrite/AccessPathExpressionCollector.java | 136 +-
.../nereids/rules/rewrite/AccessPathInfo.java | 2 +-
.../rules/rewrite/AccessPathPlanCollector.java | 13 +-
.../rules/rewrite/DistinctWindowExpression.java | 4 +
.../rules/rewrite/InferSetOperatorDistinct.java | 131 +-
.../doris/nereids/rules/rewrite/MergeTopNs.java | 15 +-
.../nereids/rules/rewrite/MetaPathStriper.java | 300 +
.../nereids/rules/rewrite/NestedColumnPruning.java | 812 +-
.../rules/rewrite/PullUpProjectUnderTopN.java | 2 +-
.../rewrite/PushDownAggThroughJoinOneSide.java | 276 -
.../rules/rewrite/PushDownDistinctThroughJoin.java | 97 -
.../rewrite/eageraggregation/BilateralState.java | 110 +
.../rewrite/eageraggregation/EagerAggHints.java | 159 +
.../rewrite/eageraggregation/EagerAggRewriter.java | 916 +-
.../eageraggregation/PushDownAggContext.java | 75 +-
.../eageraggregation/PushDownAggregation.java | 67 +-
.../trees/copier/LogicalPlanDeepCopier.java | 5 +-
.../nereids/trees/expressions/Expression.java | 2 +-
.../doris/nereids/trees/expressions/IsFalse.java | 90 +
.../doris/nereids/trees/expressions/IsTrue.java | 90 +
.../trees/expressions/functions/agg/AvgMap.java | 97 +
.../trees/expressions/functions/agg/CountMap.java | 53 +
.../functions/agg/MapAggregateFunction.java | 87 +
.../trees/expressions/functions/agg/MaxMap.java | 76 +
.../trees/expressions/functions/agg/MinMap.java | 76 +
.../trees/expressions/functions/agg/Retention.java | 11 +
.../trees/expressions/functions/agg/Sum0.java | 2 +-
.../trees/expressions/functions/agg/SumMap.java | 109 +
.../executable/DateTimeExtractAndTransform.java | 16 +-
.../functions/executable/StringArithmetic.java | 357 +-
.../expressions/functions/scalar/ArrayFirst.java | 33 +-
.../expressions/functions/scalar/ArrayLast.java | 33 +-
.../expressions/functions/scalar/ArraySort.java | 7 +
.../expressions/functions/scalar/SplitByChar.java | 76 -
.../expressions/visitor/ExpressionVisitor.java | 10 +
.../expressions/visitor/ScalarFunctionVisitor.java | 9 +-
.../nereids/trees/plans/DiffOutputInAsterisk.java | 9 +-
.../apache/doris/nereids/trees/plans/PlanType.java | 1 +
.../plans/commands/DeleteFromUsingCommand.java | 7 +-
.../SupportProfile.java} | 34 +-
.../trees/plans/commands/UpdateCommand.java | 7 +-
.../commands/insert/InsertIntoTableCommand.java | 16 +-
.../plans/commands/merge/MergeIntoCommand.java | 8 +-
.../job/UnassignedScanBucketOlapTableJob.java | 2 +-
.../nereids/trees/plans/logical/LogicalJoin.java | 73 +-
.../trees/plans/logical/LogicalProject.java | 64 +-
.../nereids/trees/plans/logical/LogicalTopN.java | 2 +-
.../nereids/trees/plans/logical/LogicalWindow.java | 17 +-
.../org/apache/doris/planner/AddLocalExchange.java | 152 +
.../org/apache/doris/planner/AggregationNode.java | 168 +-
.../org/apache/doris/planner/AnalyticEvalNode.java | 84 +-
.../apache/doris/planner/AssertNumRowsNode.java | 18 +-
.../doris/planner/BucketedAggregationNode.java | 7 +-
.../java/org/apache/doris/planner/CTEScanNode.java | 10 +
.../java/org/apache/doris/planner/DataSink.java | 5 +
.../org/apache/doris/planner/EmptySetNode.java | 10 +
.../java/org/apache/doris/planner/ExceptNode.java | 6 +
.../org/apache/doris/planner/ExchangeNode.java | 38 +-
.../org/apache/doris/planner/HashJoinNode.java | 109 +
.../org/apache/doris/planner/HiveTableSink.java | 2 +-
.../org/apache/doris/planner/IntersectNode.java | 6 +
.../apache/doris/planner/LocalExchangeNode.java | 357 +
.../apache/doris/planner/MaterializationNode.java | 18 +-
.../apache/doris/planner/NestedLoopJoinNode.java | 63 +-
.../org/apache/doris/planner/OlapScanNode.java | 18 +
.../apache/doris/planner/PartitionSortNode.java | 44 +
.../org/apache/doris/planner/PlanFragment.java | 2 +-
.../java/org/apache/doris/planner/PlanNode.java | 361 +-
.../org/apache/doris/planner/RecursiveCteNode.java | 50 +
.../apache/doris/planner/RecursiveCteScanNode.java | 12 +-
.../java/org/apache/doris/planner/RepeatNode.java | 27 +-
.../org/apache/doris/planner/RuntimeFilter.java | 2 +-
.../java/org/apache/doris/planner/ScanNode.java | 16 +-
.../java/org/apache/doris/planner/SelectNode.java | 18 +-
.../org/apache/doris/planner/SetOperationNode.java | 59 +
.../java/org/apache/doris/planner/SortNode.java | 58 +-
.../apache/doris/planner/TableFunctionNode.java | 24 +
.../java/org/apache/doris/planner/UnionNode.java | 2 +-
.../java/org/apache/doris/qe/AuditLogHelper.java | 8 +-
.../java/org/apache/doris/qe/ConnectPoolMgr.java | 2 +-
.../main/java/org/apache/doris/qe/Coordinator.java | 5 +-
.../org/apache/doris/qe/NereidsCoordinator.java | 11 +
.../java/org/apache/doris/qe/SessionVariable.java | 95 +
.../java/org/apache/doris/qe/StmtExecutor.java | 30 +-
.../qe/runtime/RuntimeFiltersThriftBuilder.java | 118 +-
.../doris/qe/runtime/ThriftPlansBuilder.java | 16 +-
.../apache/doris/service/FrontendServiceImpl.java | 10 +-
.../doris/tablefunction/MetadataGenerator.java | 4 +-
.../java/org/apache/doris/catalog/TypeTest.java | 4 +-
.../doris/cloud/CloudWarmUpJobTableFilterTest.java | 5 +
.../org/apache/doris/cloud/CloudWarmUpJobTest.java | 232 +
.../org/apache/doris/cloud/WarmUpStatsTest.java | 33 +
.../apache/doris/common/PropertyAnalyzerTest.java | 22 +
.../datasource/hive/HMSExternalTableTest.java | 9 +-
.../datasource/hive/HiveMetaStoreCacheTest.java | 15 +
.../datasource/metacache/MetaCacheEntryTest.java | 197 +-
.../property/storage/S3PropertiesTest.java | 19 +
.../apache/doris/httpv2/rest/LoadActionTest.java | 71 +
.../streaming/PostgresResourceValidatorTest.java | 45 +
.../StreamingInsertJobAdvanceSplitsTest.java | 160 +
.../StreamingMultiTblTaskTimeoutTest.java | 89 +
.../JdbcSourceOffsetProviderAsyncSplitTest.java | 9 +-
.../JdbcSourceOffsetProviderErrorHandlingTest.java | 106 +
.../routineload/RoutineLoadTaskSchedulerTest.java | 103 +
.../java/org/apache/doris/metric/MetricsTest.java | 51 +
.../RuntimeFilterPartitionPruneClassifierTest.java | 78 +
.../apache/doris/nereids/mv/PredicatesTest.java | 234 +-
.../doris/nereids/parser/NereidsParserTest.java | 41 +-
.../postprocess/TopnLazyMaterializeTest.java | 70 +
.../materialize/MaterializeProbeVisitorTest.java | 71 +-
.../rules/analysis/BindSlotReferenceTest.java | 44 -
.../nereids/rules/analysis/BindUsingJoinTest.java | 407 +
.../analysis/CheckExpressionLegalityTest.java | 10 +
.../rules/analysis/ExpressionAnalyzerTest.java | 37 +
.../rules/analysis/NormalizeAggregateTest.java | 67 +
.../analysis/OnlyFullGroupByConstantTest.java | 100 +
.../GeneratePartitionTopnFromWindowTest.java | 107 +
.../rewrite/InferSetOperatorDistinctTest.java | 78 +
.../nereids/rules/rewrite/MergeTopNsTest.java | 21 +
.../rules/rewrite/PruneNestedColumnTest.java | 202 +-
.../rewrite/PushDownDistinctThroughJoinTest.java | 98 -
.../rewrite/PushDownMinMaxSumThroughJoinTest.java | 356 -
.../eageraggregation/EagerAggRewriterTest.java | 215 +-
.../functions/scalar/ArrayFirstLastTest.java | 56 +
.../doris/planner/ListPartitionPrunerV2Test.java | 12 +-
.../planner/LocalShuffleNodeCoverageTest.java | 783 ++
.../java/org/apache/doris/planner/PlanShape.java | 335 +
.../org/apache/doris/planner/PlanShapeDsl.java | 152 +
.../apache/doris/qe/LocalExchangePlannerTest.java | 721 ++
.../org/apache/doris/qe/SessionVariablesTest.java | 39 +
.../runtime/RuntimeFiltersThriftBuilderTest.java | 158 +-
.../apache/doris/filesystem/s3/S3FileSystem.java | 34 +
.../filesystem/s3/S3FileSystemProperties.java | 5 +
.../doris/filesystem/s3/S3FileSystemTest.java | 216 +
.../filesystem/spi/S3CompatibleFileSystem.java | 362 +-
.../java/org/apache/doris/catalog/VariantType.java | 5 +
fs_brokers/cdc_client/pom.xml | 14 +
.../apache/doris/cdcclient/common/Constants.java | 12 +
.../org/apache/doris/cdcclient/common/Env.java | 221 +-
.../cdcclient/controller/ClientController.java | 35 +-
.../cdcclient/service/PipelineCoordinator.java | 114 +-
.../doris/cdcclient/sink/DorisBatchStreamLoad.java | 41 +
.../deserialize/DebeziumJsonDeserializer.java | 50 +-
.../source/reader/AbstractCdcSourceReader.java | 9 +
.../source/reader/JdbcIncrementalSourceReader.java | 61 +-
.../cdcclient/source/reader/SourceReader.java | 7 +
.../source/reader/mysql/MySqlSourceReader.java | 73 +-
.../reader/postgres/PostgresSourceReader.java | 164 +-
.../apache/doris/cdcclient/utils/ConfigUtil.java | 27 +
.../org/apache/doris/cdcclient/utils/HttpUtil.java | 6 +-
.../cdcclient/itcase/CdcClientReadHarness.java | 13 +-
.../cdcclient/itcase/CdcClientWriteHarness.java | 13 +-
.../itcase/MySqlStartupGtidOffsetITCase.java | 165 +
.../cdcclient/itcase/MySqlTimeRangeITCase.java | 149 +
.../itcase/MySqlTypeConsistencyITCase.java | 214 +
.../cdcclient/itcase/PostgresTimeRangeITCase.java | 126 +
.../itcase/PostgresTypeConsistencyITCase.java | 206 +
.../deserialize/DebeziumJsonDeserializerTest.java | 104 +
.../reader/mysql/GtidMultiIntervalOffsetTest.java | 95 +
.../source/reader/mysql/MySqlSourceReaderTest.java | 55 +
.../doris/cdcclient/utils/ConfigUtilTest.java | 59 +
gensrc/thrift/PaloInternalService.thrift | 4 +-
gensrc/thrift/Partitions.thrift | 85 +
gensrc/thrift/PlanNodes.thrift | 22 +-
.../brown_p2/sql/CPUNetworkUtilization_order.out | 6 +-
.../one_level_nestedtypes_with_s3data.out | 52 +-
.../ddl/create_nestedtypes_with_schemachange.out | 12 +-
.../three_level_nestedtypes_with_s3data.out | 11998 +++++++++----------
.../two_level_nestedtypes_with_s3data.out | 4223 +++----
.../delete_p0/test_offset_only_delete_leak.out | 22 +
.../sql-functions/doc_bitmap_functions_test.out | 7 -
.../data/export_p0/test_export_data_types.out | 25 +-
.../hive/test_hive_partition_values_tvf.out | 3 +-
.../hive/test_hive_serde_prop.out | 24 +
.../jdbc/test_sqlserver_jdbc_catalog.out | 12 +
.../cdc/test_streaming_mysql_job_composite_pk.out | 2 +-
.../data/load_p0/http_stream/test_compress.csv.zst | Bin 0 -> 42 bytes
.../http_stream/test_group_commit_http_stream.out | 4 +
...scan_filtered_rows_not_pollute_load_counter.out | 15 +
.../data/load_p0/stream_load/basic_data.csv.zst | Bin 0 -> 4207 bytes
.../stream_load/basic_data_by_line.json.zst | Bin 0 -> 3461 bytes
.../data/load_p0/stream_load/test_compress.csv.zst | Bin 0 -> 42 bytes
.../load_p0/stream_load/test_compress_type.out | 2 +-
.../stream_load/test_group_commit_stream_load.out | 4 +
.../agg_function/map_agg_by_key.out | 17 +
.../gen_function/unnest_order_by_list_test.out | 8 +-
.../scalar_function/concat_ws.out | 7 +
.../column_pruning/lambda_null_pruning.out | 31 +
.../column_pruning/map_contains_arg_pruning.out | 55 +
.../topn_lazy_nested_column_pruning.out | 4 +
.../infer_set_operator_distinct.out | 1256 --
.../limit_push_down/merge_topn_prefix_key.out | 11 +
.../push_down_distinct_through_join.out | 52 -
.../add_project_for_unique_function.out | 28 +-
.../sql/test_compare_expression.out | 2 +-
.../test_group_by_constant_output.out} | 10 +-
.../data/nereids_syntax_p0/test_join3.out | 29 -
.../data/nereids_syntax_p0/using_join.out | 26 +-
.../data/query_p0/aggregate/agg_group_concat.out | 9 +
.../query_p0/eager_agg/bilateral_eager_agg.out | 333 +
.../data/query_p0/eager_agg/eager_agg.out | 28 +-
.../data/query_p0/hint/test_leading.out | 390 +-
regression-test/data/query_p0/join/test_join3.out | 9 +-
.../test_multilevel_join_agg_local_shuffle.out | 814 ++
.../data/query_p0/join/test_outer_join.out | 2 +-
.../query_p0/join/test_using_join_merge_key.out | 39 +
.../data/query_p0/keyword/test_keyword.out | 398 +-
.../query_p0/partition_topn/check_partitionkey.out | 19 +
.../runtime_filter/rf_partition_pruning.out | 15 +
.../data/query_p0/show/test_show_create_table.out | 6 -
.../array_functions/test_array_first.out | 3 +
.../array_functions/test_array_last.out | 3 +
.../sql_functions/test_is_true_false_predicate.out | 23 +
.../window_functions/test_nthvalue_function.out | 5 +
.../tpcds_sf100/noStatsRfPrune/query14.out | 92 +-
.../tpcds_sf100/noStatsRfPrune/query75.out | 84 +-
.../tpcds_sf100/noStatsRfPrune/query8.out | 38 +-
.../tpcds_sf100/no_stats_shape/query14.out | 110 +-
.../tpcds_sf100/no_stats_shape/query75.out | 84 +-
.../tpcds_sf100/no_stats_shape/query8.out | 38 +-
.../shape_check/tpcds_sf100/rf_prune/query14.out | 8 +-
.../shape_check/tpcds_sf100/rf_prune/query3.out | 19 +-
.../shape_check/tpcds_sf100/rf_prune/query38.out | 27 +-
.../shape_check/tpcds_sf100/rf_prune/query42.out | 9 +-
.../shape_check/tpcds_sf100/rf_prune/query52.out | 9 +-
.../shape_check/tpcds_sf100/rf_prune/query55.out | 9 +-
.../shape_check/tpcds_sf100/rf_prune/query8.out | 28 +-
.../shape_check/tpcds_sf100/rf_prune/query87.out | 27 +-
.../data/shape_check/tpcds_sf100/shape/query14.out | 8 +-
.../data/shape_check/tpcds_sf100/shape/query3.out | 19 +-
.../data/shape_check/tpcds_sf100/shape/query38.out | 27 +-
.../data/shape_check/tpcds_sf100/shape/query42.out | 9 +-
.../data/shape_check/tpcds_sf100/shape/query52.out | 9 +-
.../data/shape_check/tpcds_sf100/shape/query55.out | 9 +-
.../data/shape_check/tpcds_sf100/shape/query8.out | 28 +-
.../data/shape_check/tpcds_sf100/shape/query87.out | 27 +-
.../tpcds_sf1000/bs_downgrade_shape/query8.out | 28 +-
.../data/shape_check/tpcds_sf1000/hint/query14.out | 8 +-
.../data/shape_check/tpcds_sf1000/hint/query38.out | 27 +-
.../data/shape_check/tpcds_sf1000/hint/query42.out | 9 +-
.../data/shape_check/tpcds_sf1000/hint/query52.out | 9 +-
.../data/shape_check/tpcds_sf1000/hint/query8.out | 28 +-
.../data/shape_check/tpcds_sf1000/hint/query87.out | 27 +-
.../shape_check/tpcds_sf1000/shape/query14.out | 8 +-
.../data/shape_check/tpcds_sf1000/shape/query3.out | 19 +-
.../shape_check/tpcds_sf1000/shape/query38.out | 27 +-
.../shape_check/tpcds_sf1000/shape/query42.out | 9 +-
.../shape_check/tpcds_sf1000/shape/query52.out | 9 +-
.../shape_check/tpcds_sf1000/shape/query55.out | 9 +-
.../data/shape_check/tpcds_sf1000/shape/query8.out | 28 +-
.../shape_check/tpcds_sf1000/shape/query87.out | 27 +-
.../tpcds_sf1000_nopkfk/shape/query14.out | 8 +-
.../tpcds_sf1000_nopkfk/shape/query3.out | 19 +-
.../tpcds_sf1000_nopkfk/shape/query38.out | 27 +-
.../tpcds_sf1000_nopkfk/shape/query42.out | 9 +-
.../tpcds_sf1000_nopkfk/shape/query52.out | 9 +-
.../tpcds_sf1000_nopkfk/shape/query55.out | 9 +-
.../tpcds_sf1000_nopkfk/shape/query8.out | 28 +-
.../tpcds_sf1000_nopkfk/shape/query87.out | 27 +-
.../shape_check/tpcds_sf10t_orc/shape/query14.out | 68 +-
.../shape_check/tpcds_sf10t_orc/shape/query75.out | 111 +-
.../shape_check/tpcds_sf10t_orc/shape/query8.out | 38 +-
.../runtime_filter/test_pushdown_setop.out | 10 +-
.../test_variant_compaction_with_sparse_limit.out | 6 +-
.../test_insert_json_object_to_variant.out | 7 +
.../plugins/plugin_profile_plan_tree.groovy | 298 +
.../plugins_create_table_nested_type.groovy | 4 +-
.../test_audit_log_hint_session_context.groovy | 79 +
.../suites/auth_call/test_show_charset_auth.groovy | 3 +-
...est_balance_use_compute_group_properties.groovy | 1 +
.../cloud_p0/balance/test_balance_warm_up.groovy | 1 +
.../test_balance_warm_up_sync_global_config.groovy | 1 +
.../test_balance_warm_up_task_abnormal.groovy | 1 +
.../test_balance_warm_up_use_peer_cache.groovy | 1 +
.../balance/test_peer_read_async_warmup.groovy | 1 +
.../test_txn_insert_table_update_time.groovy | 66 +
.../test_time_series_compaction_level2.groovy | 2 +-
.../create_nestedtypes_with_schemachange.groovy | 2 +-
.../test_nested_types_insert_into_with_s3.groovy | 1 +
.../three_level_nestedtypes_with_s3data.groovy | 150 +-
.../two_level_nestedtypes_with_s3data.groovy | 89 +-
.../delete_p0/test_offset_only_delete_leak.groovy | 57 +
.../sql-functions/doc_bitmap_functions_test.groovy | 11 +-
.../export_p0/test_outfile_datetimev2_scale.groovy | 110 +
.../test_export_variant_10k_columns.groovy | 4 +-
.../hive/test_hive_partition_values_tvf.groovy | 5 +-
.../hive/test_hive_serde_prop.groovy | 20 +
.../hive/write/test_hive_ctas_to_doris.groovy | 2 +
.../write/test_iceberg_write_partition_path.groovy | 88 +
...st_jdbc_refresh_catalog_manual_miss_load.groovy | 243 +
.../jdbc/test_sqlserver_jdbc_catalog.groovy | 28 +
...index_compound_directory_fault_injection.groovy | 5 +-
.../test_variant_bloom_filter.groovy | 49 +
.../get/test_be_stack_trace_api.groovy | 169 +
.../mow_insert_with_partition_drop.groovy | 17 +-
.../test_streaming_mysql_job_composite_pk.groovy | 4 +-
...gres_job_slot_dropped_during_incremental.groovy | 302 +
...st_streaming_postgres_job_special_offset.groovy | 31 +
.../load/insert/test_array_string_insert.groovy | 7 +-
.../test_group_commit_http_stream.groovy | 8 +-
...n_filtered_rows_not_pollute_load_counter.groovy | 94 +
.../load_p0/stream_load/test_compress_type.groovy | 43 +
.../test_group_commit_stream_load.groovy | 6 +-
.../suites/load_p2/tvf/test_s3_tvf.groovy | 10 +-
.../agg_function/map_agg_by_key.groovy | 153 +
.../gen_function/unnest_order_by_list_test.groovy | 10 +-
.../scalar_function/Array2.groovy | 4 +
.../scalar_function/concat_ws.groovy | 15 +-
.../test_enable_local_exchange_before_agg.groovy | 157 +
.../test_local_shuffle_fe_be_consistency.groovy | 755 ++
.../test_local_shuffle_global_hash_require.groovy | 410 +
.../test_local_shuffle_recursive_cte.groovy | 181 +
.../test_local_shuffle_rqg_bugs.groovy | 1567 +++
.../test_old_coordinator_local_shuffle.groovy | 99 +
.../column_pruning/lambda_null_pruning.groovy | 150 +
.../column_pruning/map_contains_arg_pruning.groovy | 215 +
.../column_pruning/null_column_pruning.groovy | 17 +-
.../string_length_column_pruning.groovy | 53 +-
.../topn_lazy_nested_column_pruning.groovy | 103 +
.../infer_set_operator_distinct.groovy | 363 -
.../limit_push_down/merge_topn_prefix_key.groovy | 63 +
.../nereids_rules_p0/pkfk/eliminate_inner.groovy | 1 +
.../push_down_distinct_through_join.groovy | 67 -
.../push_down_multi_filter_through_window.groovy | 57 +-
.../test_group_by_constant_output.groovy | 46 +
.../suites/nereids_syntax_p0/test_join3.groovy | 100 -
.../test_python_udaf_complex.groovy | 2 +-
.../query_p0/aggregate/agg_group_concat.groovy | 17 +-
.../query_p0/eager_agg/bilateral_eager_agg.groovy | 900 ++
.../suites/query_p0/hint/test_leading.groovy | 109 +-
.../test_multilevel_join_agg_local_shuffle.groovy | 884 ++
.../query_p0/join/test_using_join_merge_key.groovy | 139 +
.../multi_distinct/multi_distinct_window.groovy | 5 +
.../partition_topn/check_partitionkey.groovy | 160 +
.../runtime_filter/rf_partition_pruning.groovy | 46 +
.../schema_table/test_sql_block_rule_status.groovy | 7 +-
.../show/test_nereids_show_replica_dist.groovy | 12 +-
.../show/test_show_create_table_nereids.groovy | 63 -
.../test_aggregate_all_functions2.groovy | 19 +
.../test_aggregate_retention_param_limit.groovy | 44 +
.../array_functions/test_array_first.groovy | 3 +-
.../array_functions/test_array_last.groovy | 3 +-
.../datetime_functions/test_func_time.groovy | 1 +
.../string_functions/test_string_all.groovy | 12 +
.../test_is_true_false_predicate.groovy | 48 +
.../window_functions/test_nthvalue_function.groovy | 30 +-
...ptive_pipeline_task_serial_read_on_limit.groovy | 6 +-
.../suites/query_profile/dml_profile_safe.groovy | 181 +
.../suites/variant_p0/column_name.groovy | 16 +-
...est_variant_compaction_with_sparse_limit.groovy | 24 +-
.../test_insert_json_object_to_variant.groovy | 98 +
.../test_variant_search_subcolumn.groovy | 2 +
thirdparty/build-thirdparty.sh | 7 +-
thirdparty/download-thirdparty.sh | 7 -
...che-arrow-17.0.0-status-inline-static-fix.patch | 58 -
.../paimon-cpp-buildutils-static-deps.patch | 14 +
683 files changed, 46561 insertions(+), 15742 deletions(-)
delete mode 100644 be/src/core/arena_with_free_lists.h
delete mode 100644 be/src/core/data_type/nested_utils.cpp
create mode 100644 be/src/exec/sink/writer/iceberg/iceberg_partition_path.cpp
copy be/src/{util/load_util.h =>
exec/sink/writer/iceberg/iceberg_partition_path.h} (69%)
create mode 100644 be/src/exprs/aggregate/aggregate_function_map_combinator.cpp
copy
fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/common/Constants.java
=> be/src/exprs/aggregate/aggregate_function_map_combinator.h (67%)
create mode 100644 be/src/service/http/action/be_thread_stack_action.cpp
create mode 100644 be/src/service/http/action/be_thread_stack_action.h
create mode 100644 be/src/util/bthread_shared_mutex.h
create mode 100644 be/test/core/column/column_filter_helper_test.cpp
create mode 100644
be/test/core/data_type_serde/data_type_serde_variant_test.cpp
create mode 100644 be/test/core/packed_int128_test.cpp
rename be/{src/core/data_type/nested_utils.h =>
test/core/value/large_int_value_test.cpp} (50%)
create mode 100644
be/test/exec/sink/writer/iceberg/iceberg_partition_path_test.cpp
create mode 100644 be/test/exprs/aggregate/agg_percentile_reservoir_test.cpp
create mode 100644 be/test/exprs/aggregate/agg_window_nth_value_test.cpp
create mode 100644 be/test/service/http/be_thread_stack_action_test.cpp
create mode 100644 be/test/storage/index_storage_lifecycle_test.cpp
create mode 100644 be/test/storage/index_storage_schema_patch_test.cpp
create mode 100644 be/test/storage/tablet_reader_test.cpp
create mode 100644
be/test/storage/test_data/index_storage/variant_path_index.jsonl
create mode 100644
be/test/storage/variant/index_storage_variant_compaction_read_test.cpp
create mode 100644
be/test/storage/variant/index_storage_variant_compaction_schema_test.cpp
create mode 100644
be/test/storage/variant/index_storage_variant_debug_point_test.cpp
create mode 100644
be/test/storage/variant/index_storage_variant_dynamic_path_pruning_test.cpp
create mode 100644
be/test/storage/variant/index_storage_variant_expr_pushdown_test.cpp
create mode 100644
be/test/storage/variant/index_storage_variant_field_pattern_index_test.cpp
create mode 100644
be/test/storage/variant/index_storage_variant_path_index_lifecycle_test.cpp
create mode 100644
be/test/storage/variant/index_storage_variant_schema_evolution_test.cpp
create mode 100644
be/test/storage/variant/index_storage_variant_schema_patch_test.cpp
create mode 100644
be/test/storage/variant/index_storage_variant_sparse_stats_test.cpp
create mode 100644 be/test/storage/variant/index_storage_variant_test_base.h
rename be/test/storage/{segment =>
variant}/variant_column_writer_reader_test.cpp (99%)
rename be/test/storage/{compaction =>
variant}/variant_doc_mode_compaction_test.cpp (100%)
rename be/test/storage/{segment => variant}/variant_stats_calculator_test.cpp
(92%)
rename be/test/storage/{segment => variant}/variant_util_test.cpp (100%)
create mode 100644 be/test/testutil/index_storage_test_util.cpp
create mode 100644 be/test/testutil/index_storage_test_util.h
create mode 100644 be/test/util/bthread_shared_mutex_test.cpp
create mode 100644
fe/be-java-extensions/max-compute-connector/src/test/java/org/apache/doris/maxcompute/MaxComputeJniWriterTest.java
create mode 100644
fe/fe-common/src/main/java/org/apache/doris/job/cdc/StreamingTaskStatus.java
copy
fe/fe-common/src/main/java/org/apache/doris/job/cdc/request/{WriteRecordRequest.java
=> TaskFailureRequest.java} (54%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/MetaPathStriper.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/PushDownAggThroughJoinOneSide.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/PushDownDistinctThroughJoin.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/eageraggregation/BilateralState.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/eageraggregation/EagerAggHints.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/IsFalse.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/IsTrue.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/AvgMap.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/CountMap.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/MapAggregateFunction.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/MaxMap.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/MinMap.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/SumMap.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/SplitByChar.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/{DiffOutputInAsterisk.java
=> commands/SupportProfile.java} (50%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/AddLocalExchange.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/LocalExchangeNode.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/job/extensions/insert/streaming/PostgresResourceValidatorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/job/extensions/insert/streaming/StreamingInsertJobAdvanceSplitsTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/job/extensions/insert/streaming/StreamingMultiTblTaskTimeoutTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/job/offset/jdbc/JdbcSourceOffsetProviderErrorHandlingTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/analysis/BindUsingJoinTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/analysis/OnlyFullGroupByConstantTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/InferSetOperatorDistinctTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/PushDownDistinctThroughJoinTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/PushDownMinMaxSumThroughJoinTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/scalar/ArrayFirstLastTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/LocalShuffleNodeCoverageTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/PlanShape.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/PlanShapeDsl.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/qe/LocalExchangePlannerTest.java
create mode 100644
fs_brokers/cdc_client/src/test/java/org/apache/doris/cdcclient/itcase/MySqlStartupGtidOffsetITCase.java
create mode 100644
fs_brokers/cdc_client/src/test/java/org/apache/doris/cdcclient/itcase/MySqlTimeRangeITCase.java
create mode 100644
fs_brokers/cdc_client/src/test/java/org/apache/doris/cdcclient/itcase/MySqlTypeConsistencyITCase.java
create mode 100644
fs_brokers/cdc_client/src/test/java/org/apache/doris/cdcclient/itcase/PostgresTimeRangeITCase.java
create mode 100644
fs_brokers/cdc_client/src/test/java/org/apache/doris/cdcclient/itcase/PostgresTypeConsistencyITCase.java
create mode 100644
fs_brokers/cdc_client/src/test/java/org/apache/doris/cdcclient/source/reader/mysql/GtidMultiIntervalOffsetTest.java
create mode 100644
regression-test/data/delete_p0/test_offset_only_delete_leak.out
create mode 100644
regression-test/data/load_p0/http_stream/test_compress.csv.zst
create mode 100644
regression-test/data/load_p0/insert/test_scan_filtered_rows_not_pollute_load_counter.out
create mode 100644 regression-test/data/load_p0/stream_load/basic_data.csv.zst
create mode 100644
regression-test/data/load_p0/stream_load/basic_data_by_line.json.zst
create mode 100644
regression-test/data/load_p0/stream_load/test_compress.csv.zst
create mode 100644
regression-test/data/nereids_function_p0/agg_function/map_agg_by_key.out
create mode 100644
regression-test/data/nereids_rules_p0/column_pruning/lambda_null_pruning.out
create mode 100644
regression-test/data/nereids_rules_p0/column_pruning/map_contains_arg_pruning.out
delete mode 100644
regression-test/data/nereids_rules_p0/infer_set_operator_distinct/infer_set_operator_distinct.out
create mode 100644
regression-test/data/nereids_rules_p0/limit_push_down/merge_topn_prefix_key.out
delete mode 100644
regression-test/data/nereids_rules_p0/push_down_distinct_through_join/push_down_distinct_through_join.out
copy regression-test/data/{load_p0/stream_load/test_compress_type.out =>
nereids_syntax_p0/test_group_by_constant_output.out} (50%)
delete mode 100644 regression-test/data/nereids_syntax_p0/test_join3.out
create mode 100644
regression-test/data/query_p0/eager_agg/bilateral_eager_agg.out
create mode 100644
regression-test/data/query_p0/join/test_multilevel_join_agg_local_shuffle.out
create mode 100644
regression-test/data/query_p0/join/test_using_join_merge_key.out
create mode 100644
regression-test/data/query_p0/partition_topn/check_partitionkey.out
delete mode 100644
regression-test/data/query_p0/show/test_show_create_table.out
create mode 100644
regression-test/data/query_p0/sql_functions/test_is_true_false_predicate.out
create mode 100644
regression-test/data/variant_p0/test_insert_json_object_to_variant.out
create mode 100644 regression-test/plugins/plugin_profile_plan_tree.groovy
create mode 100644
regression-test/suites/audit/test_audit_log_hint_session_context.groovy
create mode 100644
regression-test/suites/cloud_p0/version/test_txn_insert_table_update_time.groovy
create mode 100644
regression-test/suites/delete_p0/test_offset_only_delete_leak.groovy
create mode 100644
regression-test/suites/export_p0/test_outfile_datetimev2_scale.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/write/test_iceberg_write_partition_path.groovy
create mode 100644
regression-test/suites/external_table_p0/jdbc/test_jdbc_refresh_catalog_manual_miss_load.groovy
create mode 100644
regression-test/suites/http_rest_api/get/test_be_stack_trace_api.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_slot_dropped_during_incremental.groovy
create mode 100644
regression-test/suites/load_p0/insert/test_scan_filtered_rows_not_pollute_load_counter.groovy
create mode 100644
regression-test/suites/nereids_function_p0/agg_function/map_agg_by_key.groovy
create mode 100644
regression-test/suites/nereids_p0/local_shuffle/test_enable_local_exchange_before_agg.groovy
create mode 100644
regression-test/suites/nereids_p0/local_shuffle/test_local_shuffle_fe_be_consistency.groovy
create mode 100644
regression-test/suites/nereids_p0/local_shuffle/test_local_shuffle_global_hash_require.groovy
create mode 100644
regression-test/suites/nereids_p0/local_shuffle/test_local_shuffle_recursive_cte.groovy
create mode 100644
regression-test/suites/nereids_p0/local_shuffle/test_local_shuffle_rqg_bugs.groovy
create mode 100644
regression-test/suites/nereids_p0/local_shuffle/test_old_coordinator_local_shuffle.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/column_pruning/lambda_null_pruning.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/column_pruning/map_contains_arg_pruning.groovy
delete mode 100644
regression-test/suites/nereids_rules_p0/infer_set_operator_distinct/infer_set_operator_distinct.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/limit_push_down/merge_topn_prefix_key.groovy
delete mode 100644
regression-test/suites/nereids_rules_p0/push_down_distinct_through_join/push_down_distinct_through_join.groovy
create mode 100644
regression-test/suites/nereids_syntax_p0/test_group_by_constant_output.groovy
delete mode 100644 regression-test/suites/nereids_syntax_p0/test_join3.groovy
create mode 100644
regression-test/suites/query_p0/eager_agg/bilateral_eager_agg.groovy
create mode 100644
regression-test/suites/query_p0/join/test_multilevel_join_agg_local_shuffle.groovy
create mode 100644
regression-test/suites/query_p0/join/test_using_join_merge_key.groovy
create mode 100644
regression-test/suites/query_p0/partition_topn/check_partitionkey.groovy
delete mode 100644
regression-test/suites/query_p0/show/test_show_create_table_nereids.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/aggregate_functions/test_aggregate_retention_param_limit.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/test_is_true_false_predicate.groovy
create mode 100644 regression-test/suites/query_profile/dml_profile_safe.groovy
create mode 100644
regression-test/suites/variant_p0/test_insert_json_object_to_variant.groovy
delete mode 100644
thirdparty/patches/apache-arrow-17.0.0-status-inline-static-fix.patch
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
