This is an automated email from the ASF dual-hosted git repository.
kirs pushed a change to branch auto-pick-57268-branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
from d4add73f931 [feat](test)Add Azure Blob Test (#57268)
add 2ded5c72388 branch-4.0: [fix] remove useless const_cast and explain
const_cast(2) #56427 (#58009)
add 7355f76d398 branch-4.0: [fix]handle loading iceberg partitions by auth
#57988 (#58021)
add 20debebcc20 branch-4.0: [fix][arrow-flight-sql]Move ctx.clear() to the
end of close method #57858 (#58011)
add 213df2f3fd7 branch-4.0: [fix](proc) fix schema proc row data #57962
(#58016)
add d75cf309dec branch-4.0: [optimize](paimon): Avoid redundant hadoop
conf setting in each split #57950 (#58014)
add 5db833025d7 branch-4.0: [chore] (streamload) add enable stream load
profile config #57919 (#58029)
add eb0bd576e17 branch-4.0: [ut](ldap)Change the implementation of
LdapClientTest to solve the problem of pipeline out failure #57994 (#58007)
add 8f6aaa6a51b branch-4.0: [fix](hive) Fix partition path scheme mismatch
when inserting into Hive partitioned tables on object storage #57973 (#58028)
add a1b7163053b branch-4.0: [opt](nereids)estimate num_nulls for outer
join #57863 (#58022)
add de9d7fc1007 branch-4.0: [fix](executor) Fix time-sharing task executor
don't re-schedule when exceeded concurrency limit case. #57833 (#58013)
add 2264de81b89 branch-4.0: [fix](test) Support azure config for recycler
case #58026 (#58052)
add 6f207acce40 branch-4.0: [fix](case) Increase the robustness of some
docker case #57991 (#58053)
add 43aaa7b6aec branch-4.0: [Bug](scan) fix topn_next fail #57895 (#58056)
add c8f7784acac branch-4.0:[feature](mtmv)create mtmv can use view
(#56423) (#58010)
add f712c5b6e30 branch-4.0: [thirdparty](patch) Support a better way to
get offset in cctz #57999 (#58059)
add 27d4588f5f4 branch-4.0: [regression-test](variant) use s3load instead
of stream load in variant_p2 test #56795 (#58076)
add ce11bb7345d branch-4.0: [enhance](job) terminate streaming task
execute threads promptly when idle #58041 (#58064)
add 74e1a1e5b6b branch-4.0: [fix](nereids) Fix aggregate source repeat
output is different from child repeat #57840 (#58088)
add f05a582ab24 branch-4.0: [feature](cloud) Read peer be cache when
balance in same cluster #56384 (#58089)
add 356c25443c2 branch-4.0: [chore](memtable) use doris::Exception replace
std::runtime_error #58098 (#58102)
add 079996228f7 branch-4.0: [feature](jsonb) json type support group by
and distinct #57679 (#58101)
add 98896679c79 branch-4.0: [fix] remove useless const_cast and explain
const_cast(1) #55943 (#58117)
add 4105d6cc574 branch-4.0: [performance](agg) support count push agg in
no null column #58103 (#58133)
add efa23396645 branch-4.0: [enhancement](wg) print error code when delete
cgroup path failed #58126 (#58139)
add b19ca07bad1 branch-4.0: [fix](jdbc) Skip the default creation check
logic #57983 (#58121)
add 6dce942d889 branch-4.0: [Enhancement](ai) relax the matching
restriction of some AI-Functions #58077 (#58113)
add ff742c44eb1 branch-4.0: [feat](web)Adapted for Spring Boot 3 and Jetty
12 #57710 (#57782)
add 9812408dec8 branch-4.0: [improvement](error msg) prioritize retaining
the error URL and first_error_msg when truncation occurs #56759 (#58145)
add 507f29b2680 branch-4.0: [fix](cloud) avoid broadcast remote read in
topn query #58044 (#58156)
add 71f3e91b20a branch-4.0: [fix](metric) fix backend metrics missing in
fe #57935 (#58160)
add 993888e3fc9 branch-4.0: [fix](cloud) Fix cloud drop tablet tasks pile
up #58131 (#58158)
add 5e90fa2ace5 add 4.0.2-rc01 (#58167)
add 07b413228ba branch-4.0: [test](bloom filter) enhance bloom filter
regression case for recover fe configs #58148 (#58168)
add 1d63c19e3ee branch-4.0:[feature](mtmv)MTMV refresh support multi pct
tables (#58140)
add 31353bad17a branch-4.0: [fix](case) fix group commit case #58142
(#58173)
add 6b1f695f107 branch-4.0: [test](ip) fix ip_cidr_search case #58151
(#58169)
add 0cf45d18e51 branch-4.0: [opt](ann index) Introduce IDSelectorRoaring
for a faster roaring_to_faiss_selector #58095 (#58177)
add d51a15621e7 branch-4.0: [fix](file cache) Fix inverted index cache not
cleaned on compaction failure #58141 (#58165)
add 436a73b231b branch-4.0: [fix](load) Fix undefined behavior in the JSON
reader caused by multiple calls to the get_string method #58107 (#58185)
add 03da50fa6de branch-4.0: [fix](iceberg) only enable dynamic partition
pruning for identity partitions in Iceberg #58033 (#58182)
add b0b7b2a8ab8 branch-4.0: [fix](nereids)where clause should only
contains key column when create mv on unique table #57915 (#58179)
add 4e2dd1c498d branch-4.0: [fix](hive) refresh hive cache when
inconsistency #58074 (#58187)
add 40379b7a8eb branch-4.0: [fix](datatype)Fix unaligned memory access in
read_column_from_arrow #58002 (#58202)
add 032bca70636 branch-4.0: [fix](auth)Fixed an issue where the wrong
catalog was used when checking permissions with use cluster #58084 (#58191)
add 9abb789d2ac branch-4.0: [fix](cloud) Fix the issue where it takes a
long time to come alive on first boot #58152 (#58194)
add df2a963e742 [Refactor](block) pick some trim block pr #57737 #57860
#58124 (#58209)
add 8b6b871cc93 branch-4.0: [fix](test) fix regression sumRewrite #58232
(#58235)
add f79c0ddaed9 [branch-4.0](pick)expr execution now returns a Column
directly instead of inserting into a Block (#58227)
add ecdc189390a branch-4.0: [Chore](build) copy jeprof to output/be/bin
#58128 (#58207)
add 97315a8b8d0 branch-4.0: [opt](staticstis) use count(1) for rowCount
when scan full table #58153 (#58190)
add 516e65215ad branch-4.0: [fix](nereids) inferPredicate should not
pullup predicates from mark join's right child #57712 (#58211)
add 2f19e95bc08 branch-4.0: [feat](load) support merge into #57044 #58091
(#58219)
add 7ce3d6a63b1 branch-4.0: [feature](regression-plugin) support version
compare plugin with cloud #56850 (#58244)
add ab3b6638005 [fix](paimon-catalog)Fix OSS access when using DLS
endpoint (#58099) (#58226)
add 66a92031a69 branch-4.0: [feat](iceberg) Implement Iceberg
`rewrite_data_files` action for table optimization and compaction (#56413
#56638) (#57871)
add e591ce6fe92 branch-4.0: [enhancement](tde) add configuration for TDE
key rotation #58171 (#58203)
add 606756848c5 branch-4.0: [fix](datatype)Fix for unaligned memory in
arrow MapArray parsing. #58248 (#58251)
add a5aa884062b branch-4.0: [fix](mtmx) Fix coredump because common expr
push down to scannode which belongs to an agg materialized view #58038 (#58096)
add 6ae3f3afe54 branch-4.0: [test](schema-change) Minimal case for schema
change index out of bound when delete predicate column dropped #57861 (#58250)
add efb3f4a5176 branch-4.0: [fix](nereids)allow sync mv has same columns
as base table when it has where clause #58105 (#58180)
add 7989173a585 branch-4.0: [Feature] Support Doris Catalog (#55274)
(#58162)
add 58f171035fa branch-4.0: [feat](storage) introduce backpressure
algorithm to control version number (part I) #57133 (#57416)
add 74560490956 branch-4.0: [bugfix](memory) should count memory when
cancel query is called #58252 (#58256)
add ee73e97f46e branch-4.0: [chore](cloud) Expose download command in
tools/fdb/fdb_ctl.sh for convenience #58257 (#58266)
add 78da6151fa3 branch-4.0: [Test](client) Add s3 storage client test
sketelon #57456 (#58164)
add 93c8bef60ab branch-4.0: [fix](jni)Add hadoop-mapreduce-client-core
dependencies #58217 (#58267)
add ef90838145c branch-4.0: [bug](test) fix the different test case with
same table name #58197 (#58260)
add 30b51a54f9b branch-4.0: [refactor](mysql output)Use to_string when
outputting plain text to MySQL. #57824 (#58264)
add 1739237db10 branch-4.0: [fix](function) Align function signatures
between backend and frontend and remove datev1 types #56807 (#58262)
add e19909e11ed branch-4.0: [chore](proc) Fix wrong keys type in show proc
index schema #58201 (#58272)
add 751b22aba44 branch-4.0: [Improvement](join) add direct mapping opt for
join #57960 (#58309)
add 2988d887b83 branch-4.0: [fix](test) remove spark load test cases
(#58270)
add 8fa5b988793 branch-4.0: [fix](window) allow constant expression
evaluation in LAG/LEAD offset parameter #58200 (#58261)
add ae5d963dbfa branch-4.0: [fix](cases) Remove badcase
test_auto_partition_with_single_replica_insert #58259 (#58308)
add a2671c4d601 branch-4.0: [fix](regression) fix
test_iceberg_optimize_actions_ddl and test_iceberg_rewrite_data_files (#58311)
add ec8678a74b9 branch-4.0: [fix](nereids) setOperator column prunning bug
#58237 (#58318)
add 5604f3079f2 branch-4.0: [fix](type) Unexpected throw exception due to
unknown file type #57755 (#58319)
add 8eb3f1b1119 branch-4.0: [fix](regression-case) Fix
test_dml_stream_load_auth, use sync function but not async #58286 (#58314)
add 1785dac51b4 branch-4.0: [Improvement](exchange) avoid hash shuffle
when partition type is bucket shuffle and only one instance #58068 (#58206)
add 0d5b1aa6da3 branch-4.0: [fix](test) Add 'waitForSchemaChangeDone'
after drop column from table #58205 (#58303)
add 97619483118 branch-4.0: [fix](test) remove spark load test cases
#58269 (#58294)
add 5e5615f27a8 branch-4.0: [Fix](agg) fix push agg op in nullable column
before projection #58234 (#58281)
add 0cb509daa26 branch-4.0:[fix](mtmv) Fix nested mv rewritten fail when
bottom mv is partitioned (#57558) (#58277)
add 458e2ef0a33 branch-4.0: [Fix](package)Revert be-extension package
management changes due to class loading issues #58255 (#58271)
add 662c6da3a55 branch-4.0: [FIX](regression-test) Fix case
test_s3_tvf_number_range, use the right file path in HDFS #58292 (#58323)
add b916953b4b8 branch-4.0: [fix](test) fix unstable check_before_quit
cases #58295 (#58321)
add c1d2ee07788 branch-4.0: [fix](blockrule)Fix concurrency issues in
SqlBlockRuleMgr after restart fe #58296 (#58326)
add f36b2389979 branch-4.0: [fix](auth)Fixed the issue nereids not check
for the existence of permission items #58282 (#58325)
add f88c44aaaeb branch-4.0: [feature](file-cache) Implement cache warm up
select functionality. (#58315)
add 00ab6551ed1 branch-4.0: [opt](function) better signature match for
time type #58193 (#58335)
add e0035e7ebb7 branch-4.0: [chore] Opt index scan cases #57951 (#58332)
add 4003e3b3367 branch-4.0: [fix](case)Fix temp table case #58299 (#58327)
add 1d964d80f7c branch-4.0: [fix](variable) support set ON and ALL to
variable #58287 (#58329)
add 3fcfd66bc65 branch-4.0: [Fix](geo) fix memory leak in geo #58004
(#58365)
add 1e014e3ec96 branch-4.0: [opt](catalog) Improve error messages in
connectivity tests by using root cause information #58184 (#58358)
add fb4b2ed87a0 branch-4.0: [fix](deps) update hadoop libs to 3.4.2.2 to
support jdk17 #58307 (#58339)
add a78fe2e842a branch-4.0: [opt](mtmv) Support limit or topN rewrite when
materialized view contains limit or topN #55194 (#58106)
add 266da0869a2 branch-4.0: [refactor](scanner) remove scanner scheduler
class since it is already split into SimplifiedScheduler #58310 (#58346)
add 4594f6306dc branch-4.0: [Improvement](exchange) avoid random partition
send empty block #58175 (#58340)
add 51b7acafaa7 branch-4.0: [fix](inverted index) fix multi-position
phrase query handling in MultiPhraseQuery #57993 (#58337)
add 7ec36a24c8a [opt](mtmv) Support materialized view query rewriting by
join eliminate when mv use more table than query #56266 (#58108)
add f4981dbf7a2 [chore] remove info log from segment iterator (#58369)
add 99dc7079857 [refactor](index scan) Rename inverted index status to
index status (… (#58374)
add 2cae54834e1 branch-4.0: [fix](variable) fix unset global variable in
non-master FE #58285 (#58381)
add 51548db83bf branch-4.0: [fix](iceberg) Add FE refresh logging after
ALTER TABLE … EXECUTE #58355 (#58379)
add 0c9160302a8 branch-4.0: (enhanced) completed the function : century
from duckdb #57893 (#58375)
add b5a746a0f51 branch-4.0: [fix](test connection) Fix the check when only
the bucket root directory is present. #58359 (#58378)
add 919f84c5cc0 branch-4.0: [fix](jni)Adjust the statistical time of JNI
appenddata. #58224 (#58386)
add 5657f73632d branch-4.0: [chore](plan) remove ColumnStats and mem
layout on tuple #57912 (#58414)
add 6bd501c97c5 branch-4.0: [chore](function) remove useless trait
PropagateNullableOnDateV2LikeArgs #57920 (#58415)
add f50d7e75e3e branch-4.0: [fix](sql-cache) make test_query_cache_hit
work #58349 (#58387)
add 6a23383f000 branch-4.0: [fix](filecache) fix regression failure due to
data compression #58246 (#58398)
add 66269b5bcf8 branch-4.0: [fix](test)Validate database is empty before
DROP DATABASE (#58344) (#58423)
add 871f1ff16d6 branch-4.0: [fix](mtmv) Fix materialized view regression
test err #58018 (#58402)
add a1dbbcd76a2 branch-4.0: [fix](partial update) fix partial update
always failed after create rollup/MV #58003 (#58393)
add 8a164fff938 branch-4.0: [fix](inverted index) fix fs set when meet
segment corruption #58317 (#58392)
add 2849d727ceb branch-4.0: [fix](regression) Add auth regression tests
for Iceberg/Paimon system tables #58298 (#58400)
add 692dd73330d branch-4.0: [fix](cloud)Support
`cloud_tablet_rebalancer_interval_second` config dynamic modification #58198
(#58377)
add bb8c52cab86 branch-4.0: [fix](function)Let second and microsecond
functions deal time literal #56659 (#58419)
add 3b4eecb541b branch-4.0: [fix](mtmv)fix MTMV staying in sync after base
table recreate column #58087 (#58380)
add f96267492a0 branch-4.0: [fix](time) fix time_to_sec error caused by
gabage value of null value #58410 (#58431)
add 55e9be832c1 branch-4.0: [feature](function) support add/sub_time
functions #56200 (#58428)
add 2a264808005 branch-4.0: [feature](partition prune) support remove
predicates that are always true after partition prune in list partition #57169
#57688 #57817 (#58040)
add 1dc0bb1f8af branch-4.0: [improve](iceberg rest) Use
`catalog.listNamespaces();` to test connectivity to cover more properties.
#58408 (#58435)
add efcd87d75fe branch-4.0: [fix](meta)fix after the FE restarts,
ConcurrentMap becomes LinkedHashMap #58382 (#58446)
add c1bcacf391a branch-4.0: [fix](local shuffle) set enable_local_shuffle
var needForward = true #58143 (#58444)
add 1fec96f0a9a branch-4.0: [fix](cloud) Fixed uneven tablet performance
during upgrades from older versions #58135 (#58249)
add a879ecd3771 branch-4.0: [fix](nereids)fold constant rule can't fold
from_unixtime when its 1st param is decimalv3 literal #57363 (#58454)
add 80a4232a3b0 [chore](build) Optimize build script (#56027) (#58464)
add 807a6257ab5 branch-4.0: [fix](load) Load column mapping with
expressions #58353 (#58437)
add e967e78e49b branch-4.0: [improve](iceberg rest) Add a default network
connection timeout to Iceberg REST #58395 (#58436)
add 34be4746c7d branch-4.0: [fix](coordinator) prefer to cancel(Timeout)
than cancel(Finished) #58448 (#58452)
add de20dbc9043 branch-4.0: [chore](ci) adjust s3Endpoint to reduce cost
#58472 (#58474)
add 878c9d1eab3 branch-4.0: [Improvement](hash) remove nullable when
_serialize_null_into_key is false and add int72 #58316 (#58465)
add e1f5176f2a3 branch-4.0: [fix](load) Add channel records to fix the
unknown load_id error #57767 (#58440)
add da92993f888 branch-4.0: [chore](cleanup) remove useless field
is_materialized in SlotDescriptor (#58320) (#58384)
add c3edf7a3b84 branch-4.0: [fix](mtmv) Fix sync materialized view use
wrong check method when in the same regression test database #58245 (#58405)
add 5ce43acb1c9 branch-4.0: [fix](information_schema) Fix timezone format
incompatibility when using offset timezone #58412 (#58480)
add 3feea9095ae branch-4.0: [Refactor](Mysql output)Refactor PRESTO and
HIVE dialect output #58279 (#58481)
add d93826bcf28 branch-4.0: [fix](jni) Fix jni.log not printing #58457
(#58487)
add a0404b5d614 branch-4.0: [fix](ut) Fix SegmentCorruptionTest ASAN
heap-buffer-overflow #58456 (#58498)
add bf25f8a292c branch-4.0: [chore](FE) Log meta module size when doing
checkpoint #58478 (#58502)
add c4d05be47f2 branch-4.0: [fix](ann index) fix omp threads limit can not
be assigned manually #58427 (#58493)
add cadeb783ee1 branch-4.0: [Fix](p0) Remove dependency on pre-existing
doris_test database in binary digest test #58291 (#58503)
add a6b53037442 branch-4.0: [fix](nereids) make needsFinalize false for
distinct agg local phase #58460 (#58489)
add e11a0656c71 branch-4.0: [feature](catalog) support varbinary type
mapping in hive/iceberg/paimon table (#57821) (#58482)
add 8deb0a436b1 branch-4.0: [refine](expr)Use the new execute function in
the expr context. #58241 (#58488)
add 09f46e668a5 branch-4.0: [fix](test) remove lakesoul test cases #58439
(#58509)
add db58e9ec795 branch-4.0: [fix](test) fix unstable export test cases
#58442 (#58525)
add 37798bf88ca branch-4.0: [Fix](ai) Fix _exec_plan_fragment_impl meet
unknown error when call AI_Functions (#58521)
add a1de24b8232 branch-4.0: [feature](jdbc) support mapping varbinary type
in JBDC catalog #58215 (#58469)
add 5de0ea999f3 Merge branch 'branch-4.0' into auto-pick-57268-branch-4.0
No new revisions were added by this update.
Summary of changes:
be/src/agent/cgroup_cpu_ctl.cpp | 7 +-
be/src/agent/task_worker_pool.cpp | 15 +-
be/src/agent/task_worker_pool.h | 2 +-
be/src/cloud/cloud_backend_service.cpp | 24 +-
be/src/cloud/cloud_internal_service.cpp | 122 ++
be/src/cloud/cloud_internal_service.h | 5 +
be/src/cloud/cloud_meta_mgr.cpp | 13 +-
be/src/cloud/cloud_meta_mgr.h | 6 +-
be/src/cloud/cloud_storage_engine.cpp | 4 +-
be/src/cloud/cloud_storage_engine.h | 2 +-
be/src/cloud/cloud_tablet_mgr.cpp | 11 +-
be/src/cloud/cloud_warm_up_manager.cpp | 84 +
be/src/cloud/cloud_warm_up_manager.h | 28 +
be/src/cloud/config.cpp | 6 +
be/src/cloud/config.h | 4 +
be/src/common/config.cpp | 16 +-
be/src/common/config.h | 5 +
be/src/common/consts.h | 2 -
be/src/exec/decompressor.cpp | 2 +-
be/src/exec/es/es_scroll_parser.cpp | 5 +-
be/src/exec/olap_common.h | 10 +-
be/src/exec/rowid_fetcher.cpp | 23 +-
be/src/exec/schema_scanner.cpp | 1 +
be/src/exec/schema_scanner.h | 1 +
.../schema_active_queries_scanner.cpp | 2 +-
.../schema_scanner/schema_partitions_scanner.cpp | 2 +-
.../schema_scanner/schema_processlist_scanner.cpp | 2 +-
be/src/exec/table_connector.cpp | 2 +-
be/src/exec/tablet_info.cpp | 6 +
be/src/exprs/hybrid_set.h | 17 +-
be/src/geo/geo_types.cpp | 26 +-
be/src/geo/geo_types.h | 12 +-
be/src/geo/wkb_parse.cpp | 92 +-
be/src/geo/wkb_parse.h | 22 +-
be/src/geo/wkb_parse_ctx.h | 12 +-
be/src/geo/wkt_lex.l | 21 +-
be/src/geo/wkt_parse.cpp | 40 +-
be/src/geo/wkt_parse.h | 9 +-
be/src/geo/wkt_parse_ctx.h | 9 +-
be/src/geo/wkt_parse_type.h | 20 +-
be/src/geo/wkt_yacc.y | 175 +-
be/src/http/action/file_cache_action.cpp | 5 +
be/src/io/cache/block_file_cache_downloader.cpp | 43 +-
be/src/io/cache/block_file_cache_factory.cpp | 35 +
be/src/io/cache/block_file_cache_factory.h | 6 +
be/src/io/cache/block_file_cache_profile.cpp | 25 +-
be/src/io/cache/block_file_cache_profile.h | 7 +
be/src/io/cache/cached_remote_file_reader.cpp | 184 +-
be/src/io/cache/cached_remote_file_reader.h | 13 +-
be/src/io/cache/file_cache_common.h | 2 +
be/src/io/cache/peer_file_cache_reader.cpp | 167 ++
be/src/io/cache/peer_file_cache_reader.h | 82 +
be/src/io/file_factory.h | 5 +-
be/src/io/fs/azure_obj_storage_client.cpp | 2 +-
be/src/io/fs/file_reader.h | 2 +
be/src/io/fs/s3_file_reader.cpp | 17 +-
be/src/io/fs/s3_obj_storage_client.cpp | 10 +-
be/src/io/io_common.h | 6 +
be/src/olap/base_tablet.cpp | 7 +-
be/src/olap/compaction.cpp | 7 +
be/src/olap/comparison_predicate.h | 18 +-
be/src/olap/delta_writer.cpp | 16 +
be/src/olap/delta_writer.h | 3 +
be/src/olap/in_list_predicate.h | 15 +-
be/src/olap/memtable.cpp | 11 +-
be/src/olap/partial_update_info.cpp | 28 +-
be/src/olap/push_handler.cpp | 12 +-
be/src/olap/rowset/beta_rowset.cpp | 1 +
.../segment_v2/ann_index/ann_index_reader.cpp | 8 +-
.../segment_v2/ann_index/faiss_ann_index.cpp | 28 +-
.../olap/rowset/segment_v2/index_file_reader.cpp | 5 +-
.../olap/rowset/segment_v2/index_file_writer.cpp | 14 +
be/src/olap/rowset/segment_v2/index_file_writer.h | 1 +
.../inverted_index/query/query_helper.cpp | 29 +
.../segment_v2/inverted_index/query/query_helper.h | 3 +
.../rowset/segment_v2/inverted_index_common.cpp | 32 +-
.../olap/rowset/segment_v2/inverted_index_common.h | 62 +-
.../rowset/segment_v2/inverted_index_common_impl.h | 61 +
be/src/olap/rowset/segment_v2/segment.cpp | 3 +
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 43 +-
be/src/olap/rowset/segment_v2/segment_iterator.h | 14 +-
be/src/olap/rowset_builder.h | 5 +-
be/src/olap/schema_change.cpp | 3 +-
be/src/olap/storage_engine.cpp | 2 +-
be/src/olap/storage_engine.h | 4 +-
be/src/olap/storage_policy.cpp | 86 +
be/src/olap/storage_policy.h | 3 +
be/src/olap/tablet_meta.cpp | 2 +-
be/src/olap/tablet_schema.h | 1 -
be/src/pipeline/common/agg_utils.h | 9 +-
be/src/pipeline/common/distinct_agg_utils.h | 9 +-
be/src/pipeline/common/join_utils.h | 111 +-
be/src/pipeline/common/partition_sort_utils.h | 7 +-
be/src/pipeline/common/set_utils.h | 5 +
be/src/pipeline/exec/blackhole_sink_operator.cpp | 112 ++
be/src/pipeline/exec/blackhole_sink_operator.h | 90 +
be/src/pipeline/exec/es_scan_operator.cpp | 5 +-
be/src/pipeline/exec/exchange_sink_buffer.cpp | 3 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 87 +-
be/src/pipeline/exec/hashjoin_build_sink.cpp | 50 +-
be/src/pipeline/exec/hashjoin_build_sink.h | 6 +-
.../exec/join/process_hash_table_probe_impl.h | 34 +-
be/src/pipeline/exec/materialization_opertor.cpp | 5 +-
be/src/pipeline/exec/operator.cpp | 8 +-
.../exec/partitioned_aggregation_sink_operator.cpp | 2 +-
.../partitioned_aggregation_source_operator.cpp | 2 +-
.../exec/partitioned_hash_join_probe_operator.cpp | 15 +-
.../exec/partitioned_hash_join_sink_operator.cpp | 4 +-
be/src/pipeline/exec/result_sink_operator.cpp | 6 -
be/src/pipeline/exec/scan_operator.cpp | 48 +-
be/src/pipeline/exec/scan_operator.h | 2 +-
be/src/pipeline/exec/schema_scan_operator.cpp | 4 +-
be/src/pipeline/exec/schema_scan_operator.h | 5 +
be/src/pipeline/exec/spill_sort_sink_operator.cpp | 4 +-
be/src/pipeline/pipeline_fragment_context.cpp | 11 +
be/src/runtime/descriptor_helper.h | 10 +-
be/src/runtime/descriptors.cpp | 36 +-
be/src/runtime/descriptors.h | 19 +-
be/src/runtime/exec_env.cpp | 4 +-
be/src/runtime/exec_env.h | 5 +-
be/src/runtime/exec_env_init.cpp | 5 -
be/src/runtime/fragment_mgr.cpp | 8 +
be/src/runtime/load_channel_mgr.cpp | 53 +-
be/src/runtime/load_channel_mgr.h | 19 +-
be/src/runtime/memory/cache_policy.h | 8 +-
be/src/runtime/memory/memory_profile.cpp | 13 +-
be/src/runtime/process_profile.h | 2 +-
be/src/runtime/query_context.h | 19 +-
be/src/runtime/runtime_query_statistics_mgr.cpp | 20 +-
be/src/runtime/tablets_channel.cpp | 10 +-
be/src/runtime/tablets_channel.h | 1 +
be/src/runtime/thread_context.cpp | 15 -
be/src/runtime/thread_context.h | 20 +-
be/src/runtime/workload_group/workload_group.cpp | 8 +-
be/src/runtime/workload_group/workload_group.h | 10 +-
be/src/runtime/workload_management/io_context.h | 10 +
.../workload_management/resource_context.cpp | 1 +
.../runtime/workload_management/resource_context.h | 2 -
.../arrow_flight/arrow_flight_batch_reader.cpp | 5 +-
be/src/service/internal_service.cpp | 29 +-
be/src/util/arrow/row_batch.cpp | 4 +
be/src/util/disk_info_mac.cpp | 1 +
be/src/util/doris_metrics.cpp | 2 +
be/src/util/doris_metrics.h | 1 +
be/src/util/encryption_util.cpp | 2 +-
be/src/util/jni-util.cpp | 1 +
be/src/util/jsonb_document.h | 26 +-
be/src/util/lru_multi_cache.h | 2 +-
be/src/util/lru_multi_cache.inline.h | 4 +-
be/src/util/proto_util.h | 14 +-
be/src/util/quantile_state.h | 2 +-
be/src/util/runtime_profile.cpp | 6 +-
be/src/util/runtime_profile.h | 4 +-
be/src/util/s3_util.h | 1 +
be/src/util/slice.h | 2 +-
be/src/util/threadpool.cpp | 2 +
be/src/util/url_parser.cpp | 30 +-
.../aggregate_function_ai_agg.h | 11 +-
.../aggregate_function_map_v2.cpp | 2 -
.../aggregate_functions/aggregate_function_sort.h | 8 +-
.../aggregate_function_window.cpp | 22 -
be/src/vec/columns/column_varbinary.cpp | 60 +
be/src/vec/columns/column_varbinary.h | 20 +-
be/src/vec/common/hash_table/hash.h | 21 +-
be/src/vec/common/hash_table/hash_key_type.h | 6 +-
be/src/vec/common/hash_table/hash_map_context.h | 65 +
be/src/vec/common/hash_table/join_hash_table.h | 59 +-
be/src/vec/common/sort/sorter.h | 3 +-
be/src/vec/common/uint128.h | 9 +
be/src/vec/core/block.cpp | 222 +--
be/src/vec/core/block.h | 79 +-
be/src/vec/core/sort_block.cpp | 9 +-
be/src/vec/core/sort_description.h | 11 +-
.../vec/data_types/serde/data_type_array_serde.cpp | 56 +-
.../vec/data_types/serde/data_type_array_serde.h | 6 +
.../data_types/serde/data_type_bitmap_serde.cpp | 15 +
.../vec/data_types/serde/data_type_bitmap_serde.h | 3 +
.../serde/data_type_datetimev2_serde.cpp | 7 +-
.../data_types/serde/data_type_datev2_serde.cpp | 8 +-
.../data_types/serde/data_type_decimal_serde.cpp | 6 +-
.../vec/data_types/serde/data_type_hll_serde.cpp | 15 +
be/src/vec/data_types/serde/data_type_hll_serde.h | 3 +
.../vec/data_types/serde/data_type_jsonb_serde.cpp | 20 +
.../vec/data_types/serde/data_type_jsonb_serde.h | 3 +
.../vec/data_types/serde/data_type_map_serde.cpp | 64 +-
be/src/vec/data_types/serde/data_type_map_serde.h | 5 +
.../data_types/serde/data_type_nullable_serde.cpp | 48 +
.../data_types/serde/data_type_nullable_serde.h | 8 +
.../data_types/serde/data_type_number_serde.cpp | 53 +-
.../vec/data_types/serde/data_type_number_serde.h | 5 +
.../serde/data_type_quantilestate_serde.cpp | 18 +
.../serde/data_type_quantilestate_serde.h | 3 +
be/src/vec/data_types/serde/data_type_serde.cpp | 18 +
be/src/vec/data_types/serde/data_type_serde.h | 11 +
.../data_types/serde/data_type_string_serde.cpp | 26 +-
.../vec/data_types/serde/data_type_string_serde.h | 3 +
.../data_types/serde/data_type_struct_serde.cpp | 36 +-
.../vec/data_types/serde/data_type_struct_serde.h | 6 +
.../data_types/serde/data_type_varbinary_serde.cpp | 65 +
.../data_types/serde/data_type_varbinary_serde.h | 24 +-
.../vec/exec/format/arrow/arrow_stream_reader.cpp | 9 +-
be/src/vec/exec/format/column_type_convert.cpp | 9 +-
be/src/vec/exec/format/column_type_convert.h | 170 +-
be/src/vec/exec/format/json/new_json_reader.cpp | 40 +-
be/src/vec/exec/format/json/new_json_reader.h | 20 +
be/src/vec/exec/format/orc/vorc_reader.cpp | 105 +-
be/src/vec/exec/format/orc/vorc_reader.h | 2 +-
.../exec/format/parquet/parquet_column_convert.cpp | 16 +-
.../exec/format/parquet/parquet_column_convert.h | 43 +
.../vec/exec/format/parquet/parquet_thrift_util.h | 4 +-
be/src/vec/exec/format/parquet/schema_desc.cpp | 23 +-
be/src/vec/exec/format/parquet/schema_desc.h | 4 +
.../exec/format/parquet/vparquet_file_metadata.cpp | 3 +-
.../exec/format/parquet/vparquet_file_metadata.h | 2 +-
.../exec/format/parquet/vparquet_group_reader.cpp | 112 +-
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 12 +-
be/src/vec/exec/format/table/equality_delete.cpp | 42 +-
be/src/vec/exec/format/table/iceberg_reader.cpp | 22 +-
be/src/vec/exec/format/table/paimon_jni_reader.cpp | 16 +-
.../vec/exec/format/table/remote_doris_reader.cpp | 130 ++
be/src/vec/exec/format/table/remote_doris_reader.h | 70 +
be/src/vec/exec/format/wal/wal_reader.cpp | 4 +-
be/src/vec/exec/jni_connector.cpp | 4 +-
be/src/vec/exec/scan/file_scanner.cpp | 76 +-
be/src/vec/exec/scan/meta_scanner.cpp | 4 -
be/src/vec/exec/scan/olap_scanner.cpp | 27 +-
be/src/vec/exec/scan/scanner.cpp | 18 +-
be/src/vec/exec/scan/scanner_context.cpp | 21 +-
be/src/vec/exec/scan/scanner_context.h | 11 +-
be/src/vec/exec/scan/scanner_scheduler.cpp | 22 +-
be/src/vec/exec/scan/scanner_scheduler.h | 74 +-
be/src/vec/exec/vjdbc_connector.cpp | 56 +-
be/src/vec/exprs/lambda_function/lambda_function.h | 4 +-
.../lambda_function/varray_filter_function.cpp | 40 +-
.../exprs/lambda_function/varray_map_function.cpp | 83 +-
.../exprs/lambda_function/varray_sort_function.cpp | 273 +++
be/src/vec/exprs/vbitmap_predicate.cpp | 25 +-
be/src/vec/exprs/vbitmap_predicate.h | 3 +-
be/src/vec/exprs/vbloom_predicate.cpp | 25 +-
be/src/vec/exprs/vbloom_predicate.h | 3 +-
be/src/vec/exprs/vcase_expr.cpp | 32 +-
be/src/vec/exprs/vcase_expr.h | 3 +-
be/src/vec/exprs/vcast_expr.cpp | 74 +-
be/src/vec/exprs/vcast_expr.h | 6 +-
be/src/vec/exprs/vcolumn_ref.h | 10 +-
be/src/vec/exprs/vcompound_pred.h | 111 +-
be/src/vec/exprs/vdirect_in_predicate.h | 39 +-
be/src/vec/exprs/vectorized_fn_call.cpp | 55 +-
be/src/vec/exprs/vectorized_fn_call.h | 12 +-
be/src/vec/exprs/vexpr.cpp | 44 +-
be/src/vec/exprs/vexpr.h | 32 +-
be/src/vec/exprs/vexpr_context.cpp | 73 +-
be/src/vec/exprs/vexpr_context.h | 82 +-
be/src/vec/exprs/vin_predicate.cpp | 33 +-
be/src/vec/exprs/vin_predicate.h | 3 +-
be/src/vec/exprs/vinfo_func.cpp | 8 +-
be/src/vec/exprs/vinfo_func.h | 3 +-
be/src/vec/exprs/virtual_slot_ref.cpp | 33 +-
be/src/vec/exprs/virtual_slot_ref.h | 3 +-
be/src/vec/exprs/vlambda_function_call_expr.h | 5 +-
be/src/vec/exprs/vlambda_function_expr.h | 9 +-
be/src/vec/exprs/vliteral.cpp | 8 +-
be/src/vec/exprs/vliteral.h | 3 +-
be/src/vec/exprs/vmatch_predicate.cpp | 28 +-
be/src/vec/exprs/vmatch_predicate.h | 3 +-
be/src/vec/exprs/vruntimefilter_wrapper.cpp | 19 +-
be/src/vec/exprs/vruntimefilter_wrapper.h | 3 +-
be/src/vec/exprs/vsearch.cpp | 15 +-
be/src/vec/exprs/vsearch.h | 3 +-
be/src/vec/exprs/vslot_ref.cpp | 36 +-
be/src/vec/exprs/vslot_ref.h | 3 +
be/src/vec/exprs/vtopn_pred.h | 38 +-
be/src/vec/functions/ai/ai_functions.h | 47 +-
.../vec/functions/array/function_array_apply.cpp | 4 -
be/src/vec/functions/array/function_array_index.h | 16 +-
be/src/vec/functions/array/function_array_remove.h | 11 -
be/src/vec/functions/cast/cast_to_variant.h | 2 +-
be/src/vec/functions/cast/function_cast.cpp | 13 +-
be/src/vec/functions/complex_dict_hash_map.h | 8 +-
be/src/vec/functions/date_time_transforms.h | 16 +
be/src/vec/functions/function.cpp | 71 +-
be/src/vec/functions/function.h | 30 +-
be/src/vec/functions/function_bit.cpp | 16 +-
be/src/vec/functions/function_bit_count.cpp | 19 +-
.../function_date_or_datetime_computation.cpp | 179 +-
.../function_date_or_datetime_computation.h | 133 +-
.../function_date_or_datetime_computation_v2.cpp | 165 --
.../function_date_or_datetime_to_string.cpp | 4 -
.../vec/functions/function_datetime_floor_ceil.cpp | 31 +-
.../function_datetime_string_to_string.cpp | 4 -
be/src/vec/functions/function_helpers.cpp | 8 -
be/src/vec/functions/function_rpc.h | 2 +-
be/src/vec/functions/function_search.cpp | 30 +-
.../vec/functions/function_time_value_to_field.cpp | 7 +
be/src/vec/functions/function_unary_arithmetic.h | 54 +-
be/src/vec/functions/functions_comparison.h | 4 -
be/src/vec/functions/functions_geo.cpp | 4 +-
be/src/vec/functions/least_greast.cpp | 14 -
be/src/vec/functions/math.cpp | 150 +-
be/src/vec/functions/round.cpp | 1 -
be/src/vec/functions/simple_function_factory.h | 2 -
be/src/vec/functions/time_of_function.cpp | 17 -
be/src/vec/functions/to_time_function.cpp | 38 +-
be/src/vec/io/io_helper.h | 32 +-
be/src/vec/olap/block_reader.cpp | 1 -
be/src/vec/olap/vcollect_iterator.cpp | 15 +-
be/src/vec/olap/vertical_block_reader.cpp | 1 -
be/src/vec/olap/vgeneric_iterators.cpp | 14 +-
be/src/vec/olap/vgeneric_iterators.h | 7 +-
be/src/vec/runtime/vdata_stream_recvr.cpp | 4 +-
be/src/vec/runtime/vdata_stream_recvr.h | 7 +-
be/src/vec/runtime/vorc_transformer.cpp | 5 +
be/src/vec/sink/varrow_flight_result_writer.cpp | 8 +-
be/src/vec/sink/vdata_stream_sender.cpp | 5 +-
be/src/vec/sink/vmysql_result_writer.cpp | 94 +-
be/src/vec/sink/vtablet_block_convertor.cpp | 4 -
.../sink/writer/iceberg/viceberg_table_writer.cpp | 12 +-
.../sink/writer/iceberg/viceberg_table_writer.h | 3 +
be/src/vec/sink/writer/vfile_result_writer.cpp | 5 +-
be/src/vec/sink/writer/vtablet_writer.cpp | 61 +-
be/src/vec/sink/writer/vtablet_writer.h | 10 +
be/src/vec/sink/writer/vwal_writer.cpp | 3 +-
be/src/vec/spill/spill_reader.cpp | 4 +-
be/src/vec/spill/spill_writer.cpp | 3 +-
be/src/vec/utils/util.hpp | 12 +-
be/test/ai/aggregate_function_ai_agg_test.cpp | 28 +
be/test/ai/ai_function_test.cpp | 183 ++
be/test/common/config_validator_test.cpp | 46 +
.../test_data/parquet_scanner/dict-decoder.txt | 32 +-
.../test_data/parquet_scanner/test_uuid.parquet | Bin 0 -> 509 bytes
.../test_data/parquet_scanner/type-decoder.txt | 28 +-
be/test/exprs/mock_vexpr.h | 2 +
be/test/exprs/virtual_slot_ref_test.cpp | 16 +-
be/test/geo/geo_types_test.cpp | 459 +++--
be/test/geo/wkb_parse_test.cpp | 179 ++
be/test/geo/wkt_parse_test.cpp | 10 +-
be/test/io/client/s3_file_system_test.cpp | 1895 ++++++++++++++++++++
be/test/olap/collection_statistics_test.cpp | 5 +
.../rowset/segment_v2/index_reader_helper_test.cpp | 2 +-
.../segment_v2/inverted_index_file_writer_test.cpp | 49 +
.../rowset/segment_v2/segment_corruption_test.cpp | 368 ++++
be/test/olap/storage_resource_test.cpp | 109 ++
.../ann_topn_runtime_negative_test.cpp | 3 -
.../olap/vector_search/faiss_vector_index_test.cpp | 50 +
be/test/olap/vector_search/vector_search_utils.h | 3 -
be/test/olap/wal/wal_manager_test.cpp | 3 -
be/test/olap/wal/wal_reader_writer_test.cpp | 10 +-
.../pipeline/common/distinct_agg_utils_test.cpp | 7 +-
be/test/pipeline/common/set_utils_test.cpp | 6 +-
be/test/pipeline/exec/vdata_stream_recvr_test.cpp | 3 +-
.../operator/materialization_shared_state_test.cpp | 18 +-
be/test/pipeline/pipeline_test.cpp | 6 -
be/test/runtime/descriptor_test.cpp | 2 -
be/test/scan/mock_scanner_scheduler.h | 30 -
be/test/scan/scanner_context_test.cpp | 17 +-
be/test/testutil/mock/mock_data_stream_sender.h | 10 +-
.../vec/aggregate_functions/agg_collect_test.cpp | 15 +-
be/test/vec/aggregate_functions/agg_test.cpp | 161 ++
be/test/vec/columns/column_varbinary_test.cpp | 424 +++++
be/test/vec/core/block_test.cpp | 161 +-
be/test/vec/data_types/common_data_type_test.h | 7 +-
.../serde/data_type_serde_datetime_v2_test.cpp | 66 +-
.../serde/data_type_serde_decimal_test.cpp | 48 +-
.../data_types/serde/data_type_serde_map_test.cpp | 182 ++
.../serde/data_type_serde_number_test.cpp | 53 +-
.../serde/data_type_serde_string_test.cpp | 129 +-
.../serde/data_type_serde_struct_test.cpp | 162 ++
.../serde/data_type_serde_varbinary_test.cpp | 197 +-
.../vec/exec/format/parquet/parquet_expr_test.cpp | 3 +-
.../vec/exec/format/parquet/parquet_read_lines.cpp | 7 +-
.../exec/format/parquet/parquet_reader_test.cpp | 291 ++-
.../exec/format/parquet/parquet_thrift_test.cpp | 9 +-
be/test/vec/exec/orc/orc_read_lines.cpp | 6 +-
be/test/vec/exec/sort/sort_test.cpp | 2 +-
be/test/vec/exec/vfile_scanner_exception_test.cpp | 3 -
be/test/vec/exprs/try_cast_expr_test.cpp | 21 +-
.../exprs/vexpr_evalute_inverted_index_test.cpp | 11 +-
be/test/vec/exprs/vsearch_expr_test.cpp | 30 +-
.../vec/function/function_array_element_test.cpp | 36 -
be/test/vec/function/function_array_index_test.cpp | 57 -
.../vec/function/function_arrays_overlap_test.cpp | 31 -
be/test/vec/function/function_geo_test.cpp | 14 +-
be/test/vec/function/function_math_test.cpp | 40 -
be/test/vec/function/function_search_test.cpp | 85 +-
be/test/vec/function/function_time_test.cpp | 114 +-
be/test/vec/function/table_function_test.cpp | 24 -
bin/start_be.sh | 10 +-
build.sh | 53 +-
cloud/script/start.sh | 11 +-
dist/LICENSE-dist.txt | 4 -
.../scripts/create_preinstalled_scripts/run83.hql | 144 ++
...-01367323-fe57-4cf2-8d63-658136eef42a-0.parquet | Bin 0 -> 1649 bytes
...-6a7f405a-2ffe-4c8d-97b8-5a9f69a497c6-0.parquet | Bin 0 -> 1419 bytes
...-f52a6587-0fcb-4d15-895d-6be35077eb8d-0.parquet | Bin 0 -> 1649 bytes
.../index-86b1c133-2b65-48d2-97b5-1c311f4c32b3-0 | 1 +
.../index-b00cbd60-d07f-462c-9ddc-effcf2ba6377-0 | 1 +
.../index-f6d8156c-7d1e-4643-beb4-f1040d4a8b71-0} | 0
...manifest-044381f8-72c7-4bbe-b3e9-d4829b7dc2c7-0 | Bin 0 -> 778 bytes
...manifest-a5543fe0-8526-4707-83bb-4a46bae33d32-0 | Bin 0 -> 778 bytes
...manifest-e5878ae9-97ff-4d9d-9e16-3601ef09cc9b-0 | Bin 0 -> 778 bytes
...manifest-0f70c85a-f753-4ee3-b9dd-e81dd513ee3c-0 | Bin 0 -> 1782 bytes
...manifest-84997273-d8aa-452d-95b6-42c88639a8ce-0 | Bin 0 -> 1800 bytes
...manifest-f4bb99cc-ede0-4196-8a93-3685e67fa218-0 | Bin 0 -> 1800 bytes
...est-list-21d352ee-7901-4ca3-af30-dd0e43bedcb9-0 | Bin 0 -> 770 bytes
...est-list-21d352ee-7901-4ca3-af30-dd0e43bedcb9-1 | Bin 0 -> 743 bytes
...est-list-3dfd6008-44c0-4227-8a3f-cf4c96419518-0 | Bin 0 -> 743 bytes
...est-list-3dfd6008-44c0-4227-8a3f-cf4c96419518-1 | Bin 0 -> 743 bytes
...est-list-9a34dd3e-af29-4b67-81c4-db2d00637a41-0 | Bin 0 -> 646 bytes
...est-list-9a34dd3e-af29-4b67-81c4-db2d00637a41-1 | Bin 0 -> 743 bytes
.../paimon1/db1.db/binary_demo3/schema/schema-0 | 31 +
.../snapshot/EARLIEST | 0
.../{complex_all => binary_demo3}/snapshot/LATEST | 0
.../db1.db/binary_demo3/snapshot/snapshot-1 | 18 +
.../db1.db/binary_demo3/snapshot/snapshot-2 | 18 +
.../db1.db/binary_demo3/snapshot/snapshot-3 | 18 +
...-5e407798-98e4-47e9-b884-ce798c662f92-0.parquet | Bin 0 -> 5936 bytes
.../index-5913b702-bb8d-4e33-b764-78c42470e82b-0} | 0
...manifest-3369567e-e644-447e-8c91-2feb5ef9079b-0 | Bin 0 -> 778 bytes
...manifest-8b25f42e-072c-4ccb-8ebf-e5faf2c65f03-0 | Bin 0 -> 1800 bytes
...est-list-1a56808b-dfe6-4f71-a3c3-49d8b428ca8d-0 | Bin 0 -> 646 bytes
...est-list-1a56808b-dfe6-4f71-a3c3-49d8b428ca8d-1 | Bin 0 -> 743 bytes
.../db1.db/binary_size_test/schema/schema-0 | 31 +
.../snapshot/EARLIEST | 0
.../snapshot/LATEST | 0
.../db1.db/binary_size_test/snapshot/snapshot-1 | 18 +
.../create_preinstalled_scripts/iceberg/run19.sql | 87 +
.../create_preinstalled_scripts/iceberg/run21.sql | 152 ++
.../create_preinstalled_scripts/iceberg/run22.sql | 91 +
.../docker-compose/oracle/init/03-create-table.sql | 5 +
.../docker-compose/oracle/init/04-insert.sql | 4 +
.../java/org/apache/doris/avro/AvroJNIScanner.java | 2 +
fe/be-java-extensions/hadoop-deps/pom.xml | 122 ++
fe/be-java-extensions/hadoop-hudi-scanner/pom.xml | 5 -
.../apache/doris/hudi/HadoopHudiJniScanner.java | 2 +
.../iceberg-metadata-scanner/pom.xml | 1 -
.../doris/iceberg/IcebergSysTableJniScanner.java | 5 +
.../apache/doris/common/jni/MockJniScanner.java | 2 +
.../{log4j.properties => log4j2.properties} | 32 +-
.../org/apache/doris/jdbc/DB2JdbcExecutor.java | 2 +
.../org/apache/doris/jdbc/OracleJdbcExecutor.java | 5 +
.../apache/doris/jdbc/PostgreSQLJdbcExecutor.java | 2 +
.../apache/doris/jdbc/SQLServerJdbcExecutor.java | 2 +
.../org/apache/doris/jdbc/TrinoJdbcExecutor.java | 2 +
.../doris/maxcompute/MaxComputeJniScanner.java | 3 +
.../org/apache/doris/paimon/PaimonJniScanner.java | 9 +-
.../doris/paimon/PaimonSysTableJniScanner.java | 9 +-
fe/be-java-extensions/pom.xml | 1 +
fe/be-java-extensions/preload-extensions/pom.xml | 11 +-
.../trinoconnector/TrinoConnectorJniScanner.java | 3 +
fe/check/checkstyle/checkstyle.xml | 6 +
fe/fe-common/pom.xml | 27 -
.../org/apache/doris/catalog/PrimitiveType.java | 5 -
.../java/org/apache/doris/catalog/ScalarType.java | 2 +
.../main/java/org/apache/doris/common/Config.java | 35 +-
fe/fe-core/pom.xml | 106 +-
.../antlr4/org/apache/doris/nereids/DorisLexer.g4 | 1 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 38 +-
.../main/java/org/apache/doris/alter/Alter.java | 9 +-
.../doris/alter/MaterializedViewHandler.java | 4 +-
.../java/org/apache/doris/alter/RollupJobV2.java | 1 -
.../apache/doris/alter/SchemaChangeHandler.java | 2 +-
.../org/apache/doris/alter/SchemaChangeJobV2.java | 3 +-
.../org/apache/doris/analysis/AggregateInfo.java | 4 +-
.../java/org/apache/doris/analysis/BrokerDesc.java | 2 +-
.../org/apache/doris/analysis/CreateTableStmt.java | 2 +-
.../org/apache/doris/analysis/DescriptorTable.java | 150 +-
.../main/java/org/apache/doris/analysis/Expr.java | 12 -
.../org/apache/doris/analysis/GroupByClause.java | 2 +-
.../org/apache/doris/analysis/SchemaTableType.java | 4 +-
.../org/apache/doris/analysis/SlotDescriptor.java | 153 +-
.../java/org/apache/doris/analysis/SlotRef.java | 2 +-
.../java/org/apache/doris/analysis/StmtType.java | 1 +
.../java/org/apache/doris/analysis/TableRef.java | 11 +-
.../org/apache/doris/analysis/TupleDescriptor.java | 261 +--
.../org/apache/doris/backup/BackupHandler.java | 2 +-
.../java/org/apache/doris/backup/BackupJob.java | 5 +-
.../java/org/apache/doris/backup/RestoreJob.java | 2 +-
.../apache/doris/blockrule/SqlBlockRuleMgr.java | 9 +-
.../doris/catalog/AccessPrivilegeWithCols.java | 2 +-
.../doris/catalog/BuiltinScalarFunctions.java | 6 +
.../apache/doris/catalog/ColocateTableIndex.java | 3 +-
.../main/java/org/apache/doris/catalog/Column.java | 6 +-
.../java/org/apache/doris/catalog/ColumnStats.java | 176 --
.../main/java/org/apache/doris/catalog/Env.java | 10 +-
.../org/apache/doris/catalog/FunctionRegistry.java | 2 +-
.../org/apache/doris/catalog/JdbcResource.java | 5 +-
.../java/org/apache/doris/catalog/JdbcTable.java | 2 +-
.../java/org/apache/doris/catalog/KeysType.java | 3 +-
.../main/java/org/apache/doris/catalog/MTMV.java | 116 +-
.../java/org/apache/doris/catalog/OlapTable.java | 8 +-
.../java/org/apache/doris/catalog/ResourceMgr.java | 3 +-
.../java/org/apache/doris/catalog/SchemaTable.java | 7 +
.../java/org/apache/doris/catalog/TableIf.java | 3 +-
.../apache/doris/cloud/catalog/CloudReplica.java | 3 +-
.../doris/cloud/catalog/CloudTabletRebalancer.java | 24 +-
.../cloud/datasource/CloudInternalCatalog.java | 2 +-
.../doris/cloud/system/CloudSystemInfoService.java | 8 +-
.../transaction/CloudGlobalTransactionMgr.java | 8 +
.../org/apache/doris/common/NamedArguments.java | 1 +
.../doris/common/cache/NereidsSqlCacheManager.java | 2 +-
.../apache/doris/common/proc/IndexInfoProcDir.java | 2 +-
.../doris/common/proc/IndexSchemaProcNode.java | 3 +-
.../doris/common/proc/PartitionsProcDir.java | 2 +-
.../doris/common/profile/ProfileManager.java | 3 +-
.../doris/common/profile/RuntimeProfile.java | 7 +-
.../apache/doris/common/util/ClassLoaderUtils.java | 2 +-
.../org/apache/doris/common/util/ExprUtil.java | 2 +-
.../doris/common/util/FileFormatConstants.java | 1 +
.../org/apache/doris/common/util/JsonUtil.java | 12 +
.../org/apache/doris/common/util/LocationPath.java | 3 +
.../java/org/apache/doris/common/util/Util.java | 17 +-
.../apache/doris/datasource/CatalogFactory.java | 4 +
.../org/apache/doris/datasource/CatalogMgr.java | 9 +-
.../apache/doris/datasource/CatalogProperty.java | 20 +-
.../apache/doris/datasource/ExternalCatalog.java | 13 +-
.../org/apache/doris/datasource/ExternalTable.java | 2 +-
.../doris/datasource/FederationBackendPolicy.java | 2 +-
.../apache/doris/datasource/FileQueryScanNode.java | 33 +-
.../apache/doris/datasource/InitCatalogLog.java | 1 +
.../apache/doris/datasource/InitDatabaseLog.java | 1 +
.../apache/doris/datasource/InternalCatalog.java | 11 +-
.../apache/doris/datasource/TableFormatType.java | 3 +-
.../AbstractIcebergConnectivityTester.java | 13 +
.../AbstractS3CompatibleConnectivityTester.java | 23 +-
.../CatalogConnectivityTestCoordinator.java | 28 +-
.../HdfsCompatibleConnectivityTester.java | 6 +
.../HiveGlueMetaStoreConnectivityTester.java | 6 +
.../connectivity/HiveHMSConnectivityTester.java | 5 +
.../IcebergGlueMetaStoreConnectivityTester.java | 24 +
.../connectivity/IcebergHMSConnectivityTester.java | 5 +
.../IcebergRestConnectivityTester.java | 29 +-
...IcebergS3TablesMetaStoreConnectivityTester.java | 6 +
.../connectivity/MetaConnectivityTester.java | 8 +
.../connectivity/MinioConnectivityTester.java | 6 +
.../connectivity/StorageConnectivityTester.java | 8 +
.../doris/RemoteDorisCompatibleRestClient.java | 137 ++
.../doris/RemoteDorisExternalCatalog.java | 202 +++
.../doris/RemoteDorisExternalDatabase.java | 36 +
.../datasource/doris/RemoteDorisExternalTable.java | 89 +
.../datasource/doris/RemoteDorisRestClient.java | 299 +++
.../doris/source/RemoteDorisScanNode.java | 324 ++++
.../datasource/doris/source/RemoteDorisSource.java | 88 +
.../datasource/doris/source/RemoteDorisSplit.java | 53 +
.../doris/datasource/hive/HMSExternalTable.java | 46 +-
.../doris/datasource/hive/HMSTransaction.java | 7 +-
.../apache/doris/datasource/hive/HiveDlaTable.java | 10 +-
.../doris/datasource/hive/HiveMetaStoreCache.java | 7 +-
.../datasource/hive/HiveMetaStoreClientHelper.java | 20 +-
.../datasource/iceberg/IcebergNereidsUtils.java | 478 +++++
.../datasource/iceberg/IcebergTransaction.java | 171 +-
.../doris/datasource/iceberg/IcebergUtils.java | 85 +-
.../iceberg/action/BaseIcebergAction.java | 22 +-
.../action/IcebergCherrypickSnapshotAction.java | 5 +-
...ctory.java => IcebergExecuteActionFactory.java} | 26 +-
.../action/IcebergExpireSnapshotsAction.java | 6 +-
.../iceberg/action/IcebergFastForwardAction.java | 5 +-
.../action/IcebergRewriteDataFilesAction.java | 93 +-
.../action/IcebergRollbackToSnapshotAction.java | 5 +-
.../action/IcebergRollbackToTimestampAction.java | 5 +-
.../action/IcebergSetCurrentSnapshotAction.java | 5 +-
.../iceberg/rewrite/RewriteDataFileExecutor.java | 213 +++
.../iceberg/rewrite/RewriteDataFilePlanner.java | 362 ++++
.../iceberg/rewrite/RewriteDataGroup.java | 112 ++
.../iceberg/rewrite/RewriteGroupTask.java | 266 +++
.../datasource/iceberg/rewrite/RewriteResult.java | 111 ++
.../datasource/iceberg/source/IcebergScanNode.java | 57 +-
.../doris/datasource/jdbc/JdbcExternalCatalog.java | 5 +-
.../doris/datasource/jdbc/client/JdbcClient.java | 2 +
.../datasource/jdbc/client/JdbcClientConfig.java | 15 +
.../datasource/jdbc/client/JdbcDB2Client.java | 3 +
.../datasource/jdbc/client/JdbcMySQLClient.java | 13 +-
.../datasource/jdbc/client/JdbcOracleClient.java | 2 +
.../jdbc/client/JdbcPostgreSQLClient.java | 4 +-
.../jdbc/client/JdbcSQLServerClient.java | 2 +
.../doris/datasource/jdbc/source/JdbcScanNode.java | 7 +-
.../doris/datasource/odbc/source/OdbcScanNode.java | 7 +-
.../datasource/paimon/PaimonExternalTable.java | 3 +-
.../datasource/paimon/PaimonMetadataCache.java | 2 +-
.../apache/doris/datasource/paimon/PaimonUtil.java | 52 +-
.../datasource/paimon/source/PaimonScanNode.java | 17 +-
.../property/constants/RemoteDorisProperties.java | 50 +
.../property/fileformat/FileFormatProperties.java | 3 +
.../property/metastore/IcebergRestProperties.java | 17 +
.../property/storage/HdfsProperties.java | 2 +-
.../property/storage/LocalProperties.java | 2 +-
.../property/storage/OSSHdfsProperties.java | 39 +-
.../datasource/property/storage/OSSProperties.java | 13 +-
.../property/storage/StorageProperties.java | 19 +-
.../source/TrinoConnectorScanNode.java | 3 -
.../datasource/tvf/source/MetadataScanNode.java | 1 -
.../doris/deploy/impl/AmbariDeployManager.java | 309 ----
.../apache/doris/deploy/impl/K8sDeployManager.java | 413 -----
.../apache/doris/dictionary/DictionaryManager.java | 7 +-
.../fs/TransactionScopeCachingDirectoryLister.java | 2 +-
.../java/org/apache/doris/httpv2/HttpServer.java | 4 +-
.../httpv2/config/HttpToHttpsJettyConfig.java | 22 +-
.../apache/doris/httpv2/config/WebConfigurer.java | 31 +-
.../config/WebServerFactoryCustomizerConfig.java | 2 +-
.../doris/httpv2/controller/BaseController.java | 7 +-
.../doris/httpv2/controller/ConfigController.java | 4 +-
.../httpv2/controller/HardwareInfoController.java | 2 +-
.../doris/httpv2/controller/HelpController.java | 2 +-
.../doris/httpv2/controller/LogController.java | 2 +-
.../doris/httpv2/controller/LoginController.java | 4 +-
.../doris/httpv2/controller/LogoutController.java | 7 +-
.../doris/httpv2/controller/SessionController.java | 2 +-
.../doris/httpv2/controller/SystemController.java | 2 +-
.../doris/httpv2/interceptor/AuthInterceptor.java | 21 +-
.../httpv2/interceptor/ServletTraceIterceptor.java | 18 +-
.../doris/httpv2/meta/ColocateMetaService.java | 4 +-
.../org/apache/doris/httpv2/meta/MetaService.java | 4 +-
.../apache/doris/httpv2/rest/BackendsAction.java | 4 +-
.../doris/httpv2/rest/BootstrapFinishAction.java | 5 +-
.../apache/doris/httpv2/rest/CancelLoadAction.java | 5 +-
.../doris/httpv2/rest/CheckDecommissionAction.java | 4 +-
.../doris/httpv2/rest/CheckWalSizeAction.java | 4 +-
.../apache/doris/httpv2/rest/ConnectionAction.java | 4 +-
.../apache/doris/httpv2/rest/CopyIntoAction.java | 4 +-
.../apache/doris/httpv2/rest/DebugPointAction.java | 5 +-
.../doris/httpv2/rest/ExtraBasepathAction.java | 5 +-
.../doris/httpv2/rest/FeVersionInfoAction.java | 4 +-
.../apache/doris/httpv2/rest/GetDdlStmtAction.java | 4 +-
.../apache/doris/httpv2/rest/GetLogFileAction.java | 4 +-
.../doris/httpv2/rest/GetSmallFileAction.java | 4 +-
.../doris/httpv2/rest/GetStreamLoadState.java | 5 +-
.../org/apache/doris/httpv2/rest/HealthAction.java | 10 +-
.../org/apache/doris/httpv2/rest/LoadAction.java | 4 +-
.../apache/doris/httpv2/rest/MetaInfoAction.java | 4 +-
.../doris/httpv2/rest/MetaReplayerCheckAction.java | 4 +-
.../apache/doris/httpv2/rest/MetricsAction.java | 4 +-
.../apache/doris/httpv2/rest/MinidumpAction.java | 5 +-
.../apache/doris/httpv2/rest/ProfileAction.java | 4 +-
.../apache/doris/httpv2/rest/QueryStatsAction.java | 4 +-
.../doris/httpv2/rest/RestBaseController.java | 4 +-
.../apache/doris/httpv2/rest/RowCountAction.java | 4 +-
.../apache/doris/httpv2/rest/SetConfigAction.java | 4 +-
.../org/apache/doris/httpv2/rest/ShowAction.java | 4 +-
.../doris/httpv2/rest/StmtExecutionAction.java | 4 +-
.../doris/httpv2/rest/StorageTypeCheckAction.java | 4 +-
.../doris/httpv2/rest/TableQueryPlanAction.java | 4 +-
.../doris/httpv2/rest/TableRowCountAction.java | 4 +-
.../doris/httpv2/rest/TableSchemaAction.java | 56 +-
.../org/apache/doris/httpv2/rest/UploadAction.java | 4 +-
.../doris/httpv2/rest/manager/ClusterAction.java | 4 +-
.../doris/httpv2/rest/manager/HttpUtils.java | 2 +-
.../doris/httpv2/rest/manager/NodeAction.java | 4 +-
.../httpv2/rest/manager/QueryProfileAction.java | 4 +-
.../rest/response/GsonSchemaResponse.java} | 20 +-
.../httpv2/restv2/AddStoragePolicyAction.java | 4 +-
.../doris/httpv2/restv2/ESCatalogAction.java | 4 +-
.../apache/doris/httpv2/restv2/ImportAction.java | 4 +-
.../doris/httpv2/restv2/MetaInfoActionV2.java | 4 +-
.../doris/httpv2/restv2/StatisticAction.java | 4 +-
.../doris/httpv2/util/StatementSubmitter.java | 2 +-
.../util/streamresponse/JsonStreamResponse.java | 2 +-
.../util/streamresponse/StreamResponseInf.java | 3 +-
.../insertoverwrite/InsertOverwriteManager.java | 9 +-
.../org/apache/doris/job/base/AbstractJob.java | 2 +-
.../doris/job/executor/DispatchTaskHandler.java | 2 +-
.../doris/job/extensions/insert/InsertJob.java | 2 +-
.../insert/streaming/StreamingInsertJob.java | 2 +-
.../apache/doris/job/extensions/mtmv/MTMVTask.java | 87 +-
.../org/apache/doris/job/manager/JobManager.java | 2 +-
.../apache/doris/job/scheduler/JobScheduler.java | 2 +-
.../job/scheduler/StreamingTaskScheduler.java | 24 +-
.../java/org/apache/doris/load/DeleteHandler.java | 3 +-
.../org/apache/doris/load/loadv2/LoadManager.java | 2 +-
.../routineload/AbstractDataSourceProperties.java | 2 +-
.../load/routineload/KafkaRoutineLoadJob.java | 4 +-
.../doris/load/routineload/RoutineLoadManager.java | 2 +-
.../kafka/KafkaDataSourceProperties.java | 2 +-
.../org/apache/doris/master/ReportHandler.java | 2 +-
.../java/org/apache/doris/mtmv/BaseColInfo.java | 73 +
...BaseVersions.java => MTMVAnalyzeQueryInfo.java} | 31 +-
.../org/apache/doris/mtmv/MTMVBaseVersions.java | 11 +-
.../org/apache/doris/mtmv/MTMVHookService.java | 14 +
.../java/org/apache/doris/mtmv/MTMVJobManager.java | 9 +
.../apache/doris/mtmv/MTMVPartitionCheckUtil.java | 2 +-
.../doris/mtmv/MTMVPartitionExprDateTrunc.java | 43 +-
.../doris/mtmv/MTMVPartitionExprService.java | 2 +-
.../org/apache/doris/mtmv/MTMVPartitionInfo.java | 108 +-
.../org/apache/doris/mtmv/MTMVPartitionUtil.java | 187 +-
.../java/org/apache/doris/mtmv/MTMVPlanUtil.java | 304 +++-
.../org/apache/doris/mtmv/MTMVRefreshContext.java | 8 +-
.../doris/mtmv/MTMVRefreshPartitionSnapshot.java | 29 +-
.../org/apache/doris/mtmv/MTMVRefreshSnapshot.java | 24 +-
.../MTMVRelatedPartitionDescGeneratorService.java | 5 +-
.../MTMVRelatedPartitionDescInitGenerator.java | 17 +-
...latedPartitionDescOnePartitionColGenerator.java | 27 +-
.../MTMVRelatedPartitionDescRollUpGenerator.java | 33 +-
...MTMVRelatedPartitionDescSyncLimitGenerator.java | 21 +-
.../MTMVRelatedPartitionDescTransferGenerator.java | 132 ++
.../java/org/apache/doris/mtmv/MTMVRelation.java | 36 +-
.../org/apache/doris/mtmv/MTMVRelationManager.java | 109 +-
.../org/apache/doris/mtmv/MTMVRewriteUtil.java | 79 +-
.../java/org/apache/doris/mtmv/MTMVService.java | 18 +-
.../main/java/org/apache/doris/mtmv/MTMVUtil.java | 22 +-
.../doris/mtmv/RelatedPartitionDescResult.java | 25 +-
.../doris/mysql/authenticate/ldap/LdapClient.java | 4 +-
.../org/apache/doris/mysql/privilege/Auth.java | 2 +-
.../doris/mysql/privilege/GlobalPrivTable.java | 2 +-
.../mysql/privilege/PasswordPolicyManager.java | 4 +-
.../org/apache/doris/mysql/privilege/Role.java | 15 +-
.../apache/doris/mysql/privilege/UserManager.java | 2 +-
.../doris/mysql/privilege/UserRoleManager.java | 2 +-
.../org/apache/doris/nereids/CascadesContext.java | 4 +-
.../org/apache/doris/nereids/NereidsPlanner.java | 2 +-
.../org/apache/doris/nereids/StatementContext.java | 54 +
.../nereids/analyzer/UnboundBlackholeSink.java | 158 ++
.../doris/nereids/analyzer/UnboundRelation.java | 2 +-
.../glue/translator/ExpressionTranslator.java | 6 +-
.../glue/translator/PhysicalPlanTranslator.java | 84 +-
.../glue/translator/PlanTranslatorContext.java | 1 -
.../doris/nereids/jobs/executor/Rewriter.java | 9 +
.../executor/TableCollectAndHookInitializer.java | 16 +-
.../jobs/joinorder/hypergraph/HyperGraph.java | 6 +-
.../joinorder/hypergraph/bitmap/LongBitmap.java | 5 +
.../nereids/load/NereidsLoadPlanInfoCollector.java | 3 +-
.../nereids/load/NereidsLoadScanProvider.java | 4 +-
.../nereids/load/NereidsStreamLoadPlanner.java | 6 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 160 +-
.../parser/LogicalPlanBuilderForEncryption.java | 2 +-
.../apache/doris/nereids/parser/NereidsParser.java | 2 +-
.../nereids/properties/RequestPropertyDeriver.java | 8 +
.../org/apache/doris/nereids/rules/RuleSet.java | 14 +
.../org/apache/doris/nereids/rules/RuleType.java | 22 +-
.../nereids/rules/analysis/BindExpression.java | 2 +-
.../doris/nereids/rules/analysis/BindRelation.java | 3 +-
.../doris/nereids/rules/analysis/BindSink.java | 29 +-
.../rules/analysis/CollectOneLevelRelation.java | 4 +-
.../nereids/rules/analysis/CollectRelation.java | 19 +-
.../nereids/rules/analysis/UserAuthentication.java | 2 +-
.../mv/AbstractMaterializedViewAggregateRule.java | 32 +-
.../mv/AbstractMaterializedViewJoinRule.java | 4 +-
.../AbstractMaterializedViewLimitOrTopNRule.java | 75 +
.../mv/AbstractMaterializedViewRule.java | 288 ++-
.../mv/AbstractMaterializedViewScanRule.java | 11 +-
.../mv/AsyncMaterializationContext.java | 30 +
.../rules/exploration/mv/HyperGraphComparator.java | 95 +-
.../mv/InitMaterializationContextHook.java | 2 +-
...terializedViewAggregateOnNoneAggregateRule.java | 9 +-
.../mv/MaterializedViewLimitAggregateRule.java | 91 +
.../mv/MaterializedViewLimitJoinRule.java | 93 +
.../mv/MaterializedViewLimitScanRule.java | 88 +
.../mv/MaterializedViewTopNAggregateRule.java | 96 +
.../mv/MaterializedViewTopNJoinRule.java | 101 ++
.../mv/MaterializedViewTopNScanRule.java | 90 +
.../exploration/mv/MaterializedViewUtils.java | 604 ++-----
.../rules/exploration/mv/PartitionCompensator.java | 187 +-
.../mv/PartitionIncrementMaintainer.java | 856 +++++++++
.../mv/PreMaterializedViewRewriter.java | 3 -
.../rules/exploration/mv/RelatedTableInfo.java | 216 +++
.../nereids/rules/exploration/mv/StructInfo.java | 150 +-
.../exploration/mv/mapping/ExpressionMapping.java | 10 +-
.../rules/exploration/mv/mapping/SlotMapping.java | 2 +-
.../nereids/rules/expression/check/CheckCast.java | 2 +
.../rules/expression/rules/PartitionPruner.java | 131 +-
.../expression/rules/PartitionRangeExpander.java | 2 +-
.../rules/expression/rules/SimplifyCastRule.java | 16 +
.../rules/implementation/AggregateStrategies.java | 108 +-
...ogicalBlackholeSinkToPhysicalBlackholeSink.java | 43 +
.../LogicalWindowToPhysicalWindow.java | 2 +-
.../doris/nereids/rules/rewrite/ColumnPruning.java | 12 +-
.../nereids/rules/rewrite/InferPredicates.java | 6 +
.../rules/rewrite/PruneFileScanPartition.java | 10 +-
.../rules/rewrite/PruneOlapScanPartition.java | 41 +-
.../nereids/rules/rewrite/PruneOlapScanTablet.java | 2 +-
.../nereids/rules/rewrite/PullUpPredicates.java | 16 +
.../rules/rewrite/QueryPartitionCollector.java | 2 +
.../doris/nereids/stats/ExpressionEstimation.java | 2 +-
.../apache/doris/nereids/stats/JoinEstimation.java | 38 +-
.../trees/copier/LogicalPlanDeepCopier.java | 8 +-
.../trees/expressions/TimestampArithmetic.java | 20 +-
.../functions/ComputeSignatureHelper.java | 111 ++
.../PropagateNullableOnDateOrTimeLikeV2Args.java | 39 -
.../expressions/functions/SearchSignature.java | 46 +-
.../expressions/functions/agg/TopNWeighted.java | 19 +-
.../functions/executable/DateTimeArithmetic.java | 13 +-
.../executable/DateTimeExtractAndTransform.java | 306 +---
.../scalar/{MinutesAdd.java => AddTime.java} | 30 +-
.../functions/scalar/{Year.java => Century.java} | 27 +-
.../functions/scalar/Crc32Internal.java | 26 +-
.../trees/expressions/functions/scalar/Date.java | 5 +-
.../expressions/functions/scalar/DateDiff.java | 9 +-
.../expressions/functions/scalar/DateFormat.java | 6 +-
.../expressions/functions/scalar/DayName.java | 9 +-
.../expressions/functions/scalar/DayOfMonth.java | 9 +-
.../expressions/functions/scalar/DayOfWeek.java | 9 +-
.../expressions/functions/scalar/DayOfYear.java | 9 +-
.../expressions/functions/scalar/DaySecondAdd.java | 4 +-
.../expressions/functions/scalar/DaysAdd.java | 4 +-
.../expressions/functions/scalar/DaysDiff.java | 12 +-
.../expressions/functions/scalar/DaysSub.java | 4 +-
.../trees/expressions/functions/scalar/Hour.java | 6 +-
.../expressions/functions/scalar/HoursAdd.java | 4 +-
.../expressions/functions/scalar/HoursDiff.java | 9 +-
.../expressions/functions/scalar/HoursSub.java | 4 +-
.../expressions/functions/scalar/LastDay.java | 4 +-
.../functions/scalar/MicroSecondTimestamp.java | 4 +-
.../functions/scalar/MicroSecondsAdd.java | 4 +-
.../functions/scalar/MicroSecondsDiff.java | 4 +-
.../functions/scalar/MicroSecondsSub.java | 4 +-
.../expressions/functions/scalar/Microsecond.java | 8 +-
.../functions/scalar/MilliSecondTimestamp.java | 4 +-
.../functions/scalar/MilliSecondsAdd.java | 4 +-
.../functions/scalar/MilliSecondsDiff.java | 4 +-
.../functions/scalar/MilliSecondsSub.java | 4 +-
.../trees/expressions/functions/scalar/Minute.java | 6 +-
.../expressions/functions/scalar/MinutesAdd.java | 4 +-
.../expressions/functions/scalar/MinutesDiff.java | 9 +-
.../expressions/functions/scalar/MinutesSub.java | 4 +-
.../trees/expressions/functions/scalar/Month.java | 8 +-
.../expressions/functions/scalar/MonthName.java | 9 +-
.../expressions/functions/scalar/MonthsAdd.java | 4 +-
.../functions/scalar/MonthsBetween.java | 4 +-
.../expressions/functions/scalar/MonthsDiff.java | 9 +-
.../expressions/functions/scalar/MonthsSub.java | 4 +-
.../expressions/functions/scalar/Quarter.java | 9 +-
.../expressions/functions/scalar/QuartersAdd.java | 4 +-
.../expressions/functions/scalar/QuartersDiff.java | 4 +-
.../expressions/functions/scalar/QuartersSub.java | 4 +-
.../trees/expressions/functions/scalar/Second.java | 6 +-
.../functions/scalar/SecondTimestamp.java | 4 +-
.../expressions/functions/scalar/SecondsAdd.java | 4 +-
.../expressions/functions/scalar/SecondsDiff.java | 9 +-
.../expressions/functions/scalar/SecondsSub.java | 4 +-
.../scalar/{MinutesAdd.java => SubTime.java} | 30 +-
.../trees/expressions/functions/scalar/Time.java | 4 +-
.../expressions/functions/scalar/TimeDiff.java | 4 +-
.../expressions/functions/scalar/Timestamp.java | 20 +-
.../trees/expressions/functions/scalar/ToDate.java | 6 +-
.../trees/expressions/functions/scalar/ToDays.java | 8 +-
.../expressions/functions/scalar/ToIso8601.java | 7 +-
.../expressions/functions/scalar/ToMonday.java | 4 +-
.../functions/scalar/UnixTimestamp.java | 6 +-
.../trees/expressions/functions/scalar/Week.java | 10 +-
.../expressions/functions/scalar/WeekOfYear.java | 9 +-
.../expressions/functions/scalar/Weekday.java | 9 +-
.../expressions/functions/scalar/WeeksAdd.java | 4 +-
.../expressions/functions/scalar/WeeksDiff.java | 9 +-
.../expressions/functions/scalar/WeeksSub.java | 4 +-
.../trees/expressions/functions/scalar/Year.java | 9 +-
.../expressions/functions/scalar/YearOfWeek.java | 4 +-
.../expressions/functions/scalar/YearWeek.java | 10 +-
.../expressions/functions/scalar/YearsAdd.java | 6 +-
.../expressions/functions/scalar/YearsDiff.java | 9 +-
.../expressions/functions/scalar/YearsSub.java | 4 +-
.../trees/expressions/functions/window/Lag.java | 2 +-
.../trees/expressions/functions/window/Lead.java | 4 +-
.../trees/expressions/literal/TimeV2Literal.java | 61 +
.../expressions/literal/VarBinaryLiteral.java | 9 +
.../literal/format/DateTimeChecker.java | 12 +-
.../expressions/literal/format/TimeChecker.java | 71 +
.../expressions/visitor/ScalarFunctionVisitor.java | 15 +
.../apache/doris/nereids/trees/plans/PlanType.java | 6 +
.../plans/commands/AdminCheckTabletsCommand.java | 2 +-
.../plans/commands/AlterRoutineLoadCommand.java | 2 +-
.../plans/commands/CreateFunctionCommand.java | 2 +-
.../commands/CreateMaterializedViewCommand.java | 3 +-
.../plans/commands/CreateTableLikeCommand.java | 2 +-
.../trees/plans/commands/DeleteFromCommand.java | 7 +-
...TableCommand.java => ExecuteActionCommand.java} | 105 +-
.../trees/plans/commands/ExplainCommand.java | 3 +
.../commands/GrantResourcePrivilegeCommand.java | 4 +-
.../plans/commands/GrantTablePrivilegeCommand.java | 4 +-
.../commands/RevokeResourcePrivilegeCommand.java | 4 +-
.../commands/RevokeTablePrivilegeCommand.java | 4 +-
.../plans/commands/ShowLoadWarningsCommand.java | 2 +-
.../trees/plans/commands/UnsetVariableCommand.java | 8 +-
.../trees/plans/commands/UpdateCommand.java | 22 +-
.../plans/commands/UpdateMvByPartitionCommand.java | 71 +-
.../commands/alter/AlterRepositoryCommand.java | 2 +-
.../BaseExecuteAction.java} | 11 +-
.../ExecuteAction.java} | 16 +-
.../ExecuteActionFactory.java} | 24 +-
.../trees/plans/commands/info/CreateMTMVInfo.java | 183 +-
.../trees/plans/commands/info/CreateTableInfo.java | 2 +-
.../commands/info/DistributionDescriptor.java | 2 +-
.../commands/info/MTMVPartitionDefinition.java | 110 +-
.../trees/plans/commands/info/RefreshMTMVInfo.java | 10 +-
.../commands/insert/AbstractInsertExecutor.java | 35 +
.../insert/BaseExternalTableInsertExecutor.java | 12 +-
...tExecutor.java => BlackholeInsertExecutor.java} | 39 +-
.../commands/insert/DictionaryInsertExecutor.java | 13 +-
.../commands/insert/IcebergRewriteExecutor.java | 60 +
.../commands/insert/InsertIntoTableCommand.java | 44 +-
.../insert/InsertOverwriteTableCommand.java | 2 +-
.../trees/plans/commands/insert/InsertUtils.java | 101 +-
.../insert/OlapGroupCommitInsertExecutor.java | 13 +-
.../plans/commands/insert/OlapInsertExecutor.java | 12 +-
.../plans/commands/insert/RewriteTableCommand.java | 326 ++++
.../plans/commands/insert/WarmupSelectCommand.java | 228 +++
.../plans/commands/merge/MergeIntoCommand.java | 530 ++++++
.../plans/commands/merge/MergeMatchedClause.java | 55 +
.../commands/merge/MergeNotMatchedClause.java | 55 +
.../plans/commands/use/UseCloudClusterCommand.java | 12 +-
.../trees/plans/logical/LogicalAggregate.java | 7 +
.../trees/plans/logical/LogicalBlackholeSink.java | 88 +
.../trees/plans/logical/LogicalCheckPolicy.java | 19 +-
.../nereids/trees/plans/logical/LogicalView.java | 2 +-
.../plans/physical/PhysicalBlackholeSink.java | 144 ++
.../trees/plans/visitor/CommandVisitor.java | 11 +-
.../plans/visitor/ExpressionLineageReplacer.java | 7 +
.../nereids/trees/plans/visitor/SinkVisitor.java | 17 +
.../org/apache/doris/nereids/types/DataType.java | 6 +-
.../apache/doris/nereids/types/VarBinaryType.java | 4 +-
.../org/apache/doris/nereids/util/DateUtils.java | 5 +-
.../apache/doris/nereids/util/ExpressionUtils.java | 27 +
.../doris/nereids/util/FrontendConjunctsUtils.java | 2 +-
.../org/apache/doris/nereids/util/PlanUtils.java | 2 +-
.../doris/nereids/util/TypeCoercionUtils.java | 16 +-
.../org/apache/doris/persist/gson/GsonUtils.java | 4 +-
.../org/apache/doris/persist/meta/MetaWriter.java | 3 +
.../org/apache/doris/planner/BlackholeSink.java | 61 +
.../doris/planner/HashDistributionPruner.java | 2 +-
.../org/apache/doris/planner/HashJoinNode.java | 76 -
.../org/apache/doris/planner/OlapScanNode.java | 15 +-
.../org/apache/doris/planner/PlanFragment.java | 2 +-
.../java/org/apache/doris/planner/PlanNode.java | 2 +-
.../java/org/apache/doris/planner/RepeatNode.java | 2 +-
.../org/apache/doris/planner/ResultFileSink.java | 3 -
.../java/org/apache/doris/planner/ScanNode.java | 2 +-
.../org/apache/doris/planner/SetOperationNode.java | 2 +-
.../java/org/apache/doris/planner/SortNode.java | 16 -
.../java/org/apache/doris/policy/PolicyMgr.java | 3 +-
.../java/org/apache/doris/qe/ConnectProcessor.java | 12 +-
.../main/java/org/apache/doris/qe/Coordinator.java | 14 +
.../org/apache/doris/qe/NereidsCoordinator.java | 4 +
.../java/org/apache/doris/qe/SessionVariable.java | 42 +-
.../java/org/apache/doris/qe/SimpleScheduler.java | 2 +-
.../main/java/org/apache/doris/qe/VariableMgr.java | 4 +-
.../org/apache/doris/qe/cache/CacheAnalyzer.java | 2 +-
.../apache/doris/qe/runtime/QueryProcessor.java | 3 +
.../doris/qe/runtime/ThriftPlansBuilder.java | 2 +-
.../WorkloadRuntimeStatusMgr.java | 54 +-
.../WorkloadSchedPolicyMgr.java | 3 +-
.../apache/doris/service/FrontendServiceImpl.java | 2 +-
.../arrowflight/FlightSqlConnectProcessor.java | 2 +-
.../apache/doris/statistics/AggStatsDerive.java | 87 -
.../doris/statistics/AnalyticEvalStatsDerive.java | 41 -
.../apache/doris/statistics/BaseStatsDerive.java | 152 --
.../org/apache/doris/statistics/DeriveFactory.java | 65 -
.../doris/statistics/EmptySetStatsDerive.java | 31 -
.../doris/statistics/HashJoinStatsDerive.java | 254 ---
.../org/apache/doris/statistics/Histogram.java | 2 +-
.../doris/statistics/HistogramCacheLoader.java | 2 +-
.../apache/doris/statistics/MysqlStatsDerive.java | 33 -
.../statistics/NestedLoopJoinStatsDerive.java | 48 -
.../apache/doris/statistics/OlapAnalysisTask.java | 2 +
.../doris/statistics/OlapScanStatsDerive.java | 93 -
.../apache/doris/statistics/SelectStatsDerive.java | 35 -
.../apache/doris/statistics/StatisticalType.java | 3 +-
.../apache/doris/statistics/StatisticsCache.java | 2 +-
.../apache/doris/statistics/StatisticsCleaner.java | 2 +-
.../doris/statistics/StatsRecursiveDerive.java | 60 -
.../doris/statistics/TableFunctionStatsDerive.java | 34 -
.../doris/statistics/util/StatisticsUtil.java | 2 +-
.../java/org/apache/doris/system/HeartbeatMgr.java | 41 +-
.../ExternalFileTableValuedFunction.java | 8 +
.../tablefunction/IcebergTableValuedFunction.java | 2 +-
.../doris/tablefunction/MetadataGenerator.java | 35 +-
.../tablefunction/PaimonTableValuedFunction.java | 2 +-
.../PartitionsTableValuedFunction.java | 2 +-
.../org/apache/doris/task/CreateReplicaTask.java | 2 +-
.../doris/transaction/DatabaseTransactionMgr.java | 2 +-
.../doris/transaction/PublishVersionDaemon.java | 2 +-
.../hadoop/hive/metastore/HiveMetaStoreClient.java | 2 +-
.../SqlBlockRuleMgrTest.java} | 31 +-
.../org/apache/doris/catalog/ColumnStatTest.java | 87 -
.../apache/doris/common/CacheBulkLoaderTest.java | 2 +-
.../doris/common/proc/IndexSchemaProcNodeTest.java | 2 +
.../doris/RemoteDorisCompatibleRestClientTest.java | 72 +
.../doris/RemoteDorisRestClientTest.java | 108 ++
.../iceberg/IcebergNereidsUtilsTest.java | 1004 +++++++++++
.../doris/datasource/iceberg/IcebergUtilsTest.java | 8 +-
.../rewrite/RewriteDataFilePlannerTest.java | 1165 ++++++++++++
.../doris/datasource/paimon/PaimonUtilTest.java | 4 +-
.../property/storage/OSSHdfsPropertiesTest.java | 67 +-
.../property/storage/OSSPropertiesTest.java | 2 +-
.../doris/deploy/AmbariDeployManagerTest.java | 101 --
.../apache/doris/deploy/K8sDeployManagerTest.java | 67 -
.../external/elasticsearch/QueryBuildersTest.java | 32 +
.../external/hms/MetastoreEventFactoryTest.java | 2 +-
.../doris/mtmv/MTMVPartitionCheckUtilTest.java | 8 +-
.../apache/doris/mtmv/MTMVPartitionUtilTest.java | 18 +-
.../org/apache/doris/mtmv/MTMVPlanUtilTest.java | 229 ++-
.../apache/doris/mtmv/MTMVRefreshSnapshotTest.java | 21 +-
.../MTMVRelatedPartitionDescGeneratorTest.java | 295 +++
...TMVRelatedPartitionDescRollUpGeneratorTest.java | 2 +-
.../apache/doris/mtmv/MTMVRelationManagerTest.java | 44 +-
.../org/apache/doris/mtmv/MTMVRelationTest.java | 117 ++
.../org/apache/doris/mtmv/MTMVRewriteUtilTest.java | 261 +++
.../apache/doris/mtmv/MTMVSchemaChangeTest.java | 94 +
.../java/org/apache/doris/mtmv/MTMVTaskTest.java | 5 +-
.../test/java/org/apache/doris/mtmv/MTMVTest.java | 7 +-
.../mysql/authenticate/ldap/LdapClientTest.java | 114 +-
.../translator/PhysicalPlanTranslatorTest.java | 43 +-
.../jobs/joinorder/hypergraph/HyperGraphTest.java | 25 +-
.../doris/nereids/memo/StructInfoMapTest.java | 8 +-
.../doris/nereids/mv/IdStatisticsMapTest.java | 5 +-
.../doris/nereids/mv/MvTableIdIsLongTest.java | 4 +-
.../nereids/mv/OptimizeGetAvailableMvsTest.java | 4 +-
.../apache/doris/nereids/mv/StructInfoTest.java | 125 ++
.../doris/nereids/parser/NereidsParserTest.java | 241 ++-
.../nereids/privileges/TestCheckPrivileges.java | 2 +-
.../rules/exploration/mv/BuildStructInfoTest.java | 107 ++
.../exploration/mv/HyperGraphComparatorTest.java | 47 +-
.../exploration/mv/MaterializedViewUtilsTest.java | 56 +-
.../exploration/mv/PartitionColumnTraceTest.java | 1245 +++++++++++++
.../nereids/rules/expression/FoldConstantTest.java | 104 +-
.../LogicalWindowToPhysicalWindowTest.java | 2 +-
.../nereids/rules/rewrite/InferPredicatesTest.java | 54 +
.../nereids/rules/rewrite/PartitionPrunerTest.java | 570 ++++++
.../trees/copier/LogicalPlanDeepCopierTest.java | 76 +-
.../functions/ComputeSignatureHelperTest.java | 40 +
.../DateTimeExtractAndTransformTest.java | 18 +
.../expressions/literal/DateTimeLiteralTest.java | 1 -
.../literal/format/TimeCheckerTest.java | 61 +
.../trees/plans/commands/BackupCommandTest.java | 2 +-
.../trees/plans/commands/RestoreCommandTest.java | 2 +-
.../commands/UseCloudClusterCommandTest.java} | 29 +-
.../plans/commands/insert/InsertUtilsTest.java | 220 +++
.../plans/commands/merge/MergeIntoCommandTest.java | 959 ++++++++++
.../doris/nereids/util/ExpressionUtilsTest.java | 46 +
.../org/apache/doris/nereids/util/PlanChecker.java | 17 +-
.../doris/nereids/util/TypeCoercionUtilsTest.java | 9 +-
.../doris/persist/gson/GsonSerializationTest.java | 75 +-
.../doris/planner/HashDistributionPrunerTest.java | 2 +-
.../org/apache/doris/planner/OlapScanNodeTest.java | 2 +-
.../doris/planner/QueryCacheNormalizerTest.java | 2 +-
.../doris/statistics/OlapAnalysisTaskTest.java | 5 +
.../apache/doris/utframe/TestWithFeService.java | 7 +
fe/hive-udf/pom.xml | 14 +
fe/pom.xml | 198 +-
gensrc/proto/data.proto | 1 +
gensrc/proto/descriptors.proto | 2 +-
gensrc/proto/internal_service.proto | 36 +
gensrc/script/gen_build_version.sh | 17 +-
gensrc/thrift/DataSinks.thrift | 5 +
gensrc/thrift/Descriptors.thrift | 14 +-
gensrc/thrift/FrontendService.thrift | 9 +-
gensrc/thrift/PaloInternalService.thrift | 4 +
gensrc/thrift/PlanNodes.thrift | 16 +
gensrc/thrift/Types.thrift | 3 +-
regression-test/conf/regression-conf.groovy | 1 +
.../data/cloud_p0/cache/ttl/test_show_ttl.out | 4 +-
.../test_function_signature_all_types.out | 553 ++++++
.../json/json_group_by_and_distinct.out | 25 +
.../sql-functions/doc_date_functions_test.out | 21 +-
.../hive/test_hive_varbinary_type.out | 261 +++
...ctions.out => test_iceberg_execute_actions.out} | 3 -
.../action/test_iceberg_rewrite_data_files.out | 70 +
...iceberg_rewrite_data_files_where_conditions.out | 38 +
..._runtime_filter_partition_pruning_transform.out | 108 ++
.../iceberg/test_iceberg_varbinary.out | 85 +
.../jdbc/test_db2_jdbc_catalog.out | 12 +
.../external_table_p0/jdbc/test_jdbc_query_tvf.out | 2 +-
.../jdbc/test_pg_jdbc_catalog.out | 7 +
.../jdbc/test_sqlserver_jdbc_catalog.out | 17 +
.../type_test/ctas/test_mysql_all_types_ctas.out | 14 +-
.../select/test_mysql_all_types_select.out | 4 +-
.../select/test_oracle_all_types_select.out | 22 +-
.../type_test/select/test_pg_all_types_select.out | 6 +-
.../type_test/tvf/test_mysql_all_types_tvf.out | 4 +-
.../lakesoul/test_lakesoul_filter.out | 8 -
.../paimon/test_paimon_catalog_varbinary.out | 29 +
.../test_remote_doris_all_types_select.out | 16 +
.../test_remote_doris_all_types_show.out | 76 +
.../remote_doris/test_remote_doris_refresh.out | 16 +
.../remote_doris/test_remote_doris_statistics.out | 20 +
.../tvf/test_hdfs_parquet_group6.out | 8 +-
.../time/test_time_function.out} | 5 +-
.../data/function_p0/time/test_time_to_sec.csv | 17 +
.../test_ip_cidr_search_with_inverted_index.out | 9 +-
.../data/load_p0/merge_into/test_merge_into.out | 21 +
.../data/load_p0/spark_load/all_types1.txt | 11 -
.../data/load_p0/spark_load/all_types2.txt | 11 -
.../data/load_p0/spark_load/test_spark_load.out | 37 -
.../stream_load/load_json_with_jsonpath.out | 10 +
.../stream_load/test_load_with_jsonpath2.json | 20 +
.../mtmv_p0/test_base_add_col_multi_level_mtmv.out | 8 +-
...est_base_alter_col_comment_multi_level_mtmv.out | 8 +-
.../test_base_alter_col_type_multi_level_mtmv.out | 8 +-
.../mtmv_p0/test_base_comment_multi_level_mtmv.out | 8 +-
.../test_base_drop_col_multi_level_mtmv.out | 8 +-
.../mtmv_p0/test_base_drop_multi_level_mtmv.out | 8 +-
regression-test/data/mtmv_p0/test_base_mtmv.out | 30 +-
.../data/mtmv_p0/test_base_recreate_col_mtmv.out | 7 +
.../mtmv_p0/test_base_recreate_on_commit_mtmv.out | 4 +-
.../test_base_rename_col_multi_level_mtmv.out | 8 +-
.../mtmv_p0/test_base_rename_multi_level_mtmv.out | 8 +-
.../test_base_rename_mv_multi_level_mtmv.out | 8 +-
.../mtmv_p0/test_base_rename_on_commit_mtmv.out | 6 +-
.../test_base_rename_p_mv_multi_level_mtmv.out | 8 +-
.../mtmv_p0/test_base_replace_multi_level_mtmv.out | 24 +-
.../test_base_replace_mv_multi_level_mtmv.out | 18 +-
.../mtmv_p0/test_base_replace_on_commit_mtmv.out | 4 +-
.../data/mtmv_p0/test_create_mtmv_with_view.out | 30 +
.../mtmv_p0/test_create_mtmv_with_view_alter.out | 19 +
.../test_create_mtmv_with_view_alter_table.out | 19 +
.../test_create_mtmv_with_view_commit.out} | 10 +-
.../test_create_mtmv_with_view_cte.out} | 10 +-
.../mtmv_p0/test_create_mtmv_with_view_mtmv.out | 20 +
.../mtmv_p0/test_create_mtmv_with_view_pct.out | 21 +
.../mtmv_p0/test_create_mtmv_with_view_rollup.out | 9 +
.../data/mtmv_p0/test_hive_pct_mtmv.out | 34 +
...mtmv.out => test_limit_partition_view_mtmv.out} | 0
.../data/mtmv_p0/test_multi_pct_list_mtmv.out | 24 +
.../data/mtmv_p0/test_multi_pct_mtmv.out | 55 +
.../data/mtmv_p0/test_multi_pct_nested_mtmv.out | 24 +
.../test_multi_pct_null_partition_mtmv.out} | 7 +-
.../data/mtmv_p0/test_multi_pct_rollup_mtmv.out | 28 +
.../mtmv_p0/test_multi_pct_union_list_mtmv.out | 28 +
.../data/mtmv_p0/test_multi_pct_union_mtmv.out | 28 +
.../data/mtmv_p0/test_multi_pct_view_mtmv.out | 24 +
.../data/mtmv_p0/test_null_multi_pct_mtmv.out | 27 +
.../data/mtmv_p0/test_view_hive_mtmv.out | 28 +
.../test_upgrade_downgrade_multi_pct_mtmv.out} | 15 +-
.../data/nereids_function_p0/scalar_function/S.out | 173 +-
.../datetime_functions/test_date_function_v2.out | 81 +
.../update/update_after_create_rollup.out | 11 +
.../infer_predicate/infer_unequal_predicates.out | 19 +-
.../multi_trace_partition_mv_rewrite.out | 41 +
.../data/nereids_rules_p0/mv/topN/topN_rewrite.out | 107 ++
.../partition_prune/list_prune_predicate.out | 16 +
.../data/nereids_rules_p0/sumRewrite.out | 58 +-
.../data/nereids_syntax_p0/lag_lead_signature.out | 25 +
.../data/nereids_syntax_p0/mv/where/k123/k123.out | 4 +
...t_auto_partition_with_single_replica_insert.csv | 78 -
...t_auto_partition_with_single_replica_insert.out | 161 --
.../binary_functions/test_binary_hex_function.out | 28 +
.../datetime_functions/test_date_function.out | 118 ++
...st_materialized_view_common_expr_push_down.out} | 6 +-
.../test_non_overlap_seg_heavy_sc.out | 5 +-
.../tpcds_sf100/noStatsRfPrune/query38.out | 78 +-
.../tpcds_sf100/noStatsRfPrune/query87.out | 78 +-
.../tpcds_sf100/no_stats_shape/query38.out | 78 +-
.../tpcds_sf100/no_stats_shape/query87.out | 78 +-
.../shape_check/tpcds_sf100/rf_prune/query38.out | 78 +-
.../shape_check/tpcds_sf100/rf_prune/query87.out | 78 +-
.../data/shape_check/tpcds_sf100/shape/query38.out | 78 +-
.../data/shape_check/tpcds_sf100/shape/query87.out | 78 +-
.../data/shape_check/tpcds_sf1000/hint/query38.out | 78 +-
.../data/shape_check/tpcds_sf1000/hint/query87.out | 78 +-
.../shape_check/tpcds_sf1000/shape/query38.out | 78 +-
.../shape_check/tpcds_sf1000/shape/query87.out | 78 +-
.../doris/regression/action/ProfileAction.groovy | 5 +-
regression-test/pipeline/cloud_p0/run.sh | 3 +-
.../pipeline/external/conf/regression-conf.groovy | 7 +
regression-test/pipeline/vault_p0/run.sh | 3 +-
.../plugins/cloud_recycler_plugin.groovy | 198 +-
.../plugins/plugin_cluster_version.groovy | 46 +-
.../suites/ann_index_p0/ann_index_only_scan.groovy | 6 +-
.../ann_index_only_scan_distance_expr.groovy | 5 +-
.../ann_index_only_scan_metric_direction.groovy | 5 +-
.../auth_call/test_dml_stream_load_auth.groovy | 21 +-
.../suites/auth_p0/test_grant_auth.groovy | 14 +
.../bloom_filter_p0/test_bloom_filter.groovy | 71 +-
.../check_before_quit/check_before_quit.groovy | 12 +-
.../cloud_p0/balance/test_balance_warm_up.groovy | 38 +-
.../test_balance_warm_up_use_peer_cache.groovy | 223 +++
...e_warm_up_with_compaction_use_peer_cache.groovy | 234 +++
.../balance/test_expanding_node_balance.groovy | 111 ++
.../read_from_peer/test_read_from_peer.groovy | 178 ++
.../cloud_p0/cache/test_topn_broadcast.groovy | 148 ++
.../cloud_p0/cache/ttl/alter_ttl_max_int64.groovy | 2 +-
.../cloud_p0/cache/ttl/create_table_like.groovy | 2 +-
.../suites/cloud_p0/cache/ttl/test_ttl.groovy | 2 +-
.../cloud_p0/cache/ttl/test_ttl_lru_evict.groovy | 2 +-
.../cloud_p0/cache/ttl/test_ttl_preempt.groovy | 2 +-
.../cloud_p0/multi_cluster/test_auto_start.groovy | 1 +
.../test_cloud_add_backend_heartbeat.groovy | 52 +
.../suites/cloud_p0/recycler/test_checker.groovy | 58 +-
.../test_clean_tablet_when_drop_force_table.groovy | 17 +-
.../test_clean_tablet_when_rebalance.groovy | 3 +-
.../warm_up_select/test_warmup_select.groovy | 113 ++
.../test_function_signature_all_types.groovy | 1044 +++++++++++
.../json/json_group_by_and_distinct.groovy | 112 ++
.../fault_tolerance_nereids.groovy | 2 +-
.../sql-functions/doc_date_functions_test.groovy | 63 +
.../manual-partitioning.md.groovy | 5 +-
.../cache/test_hive_warmup_select.groovy | 156 ++
.../export/test_export_external_table.groovy | 30 +-
.../hive/test_hive_query_cache.groovy | 88 +-
.../hive/test_hive_statistic_auto.groovy | 6 +-
.../hive/test_hive_varbinary_type.groovy | 92 +
....groovy => test_iceberg_execute_actions.groovy} | 179 +-
.../action/test_iceberg_rewrite_data_files.groovy | 495 +++++
...rewrite_data_files_expression_conversion.groovy | 430 +++++
...berg_rewrite_data_files_where_conditions.groovy | 157 ++
...ntime_filter_partition_pruning_transform.groovy | 98 +
.../iceberg/test_iceberg_sys_table_auth.groovy | 176 ++
.../iceberg/test_iceberg_varbinary.groovy | 152 ++
.../test_iceberg_write_transform_partitions.groovy | 6 +
.../test_information_schema_timezone.groovy | 11 +
.../jdbc/test_db2_jdbc_catalog.groovy | 33 +
.../jdbc/test_jdbc_query_tvf.groovy | 3 +-
.../jdbc/test_pg_jdbc_catalog.groovy | 18 +-
.../jdbc/test_sqlserver_jdbc_catalog.groovy | 19 +
.../ctas/test_mysql_all_types_ctas.groovy | 7 +-
.../select/test_mysql_all_types_select.groovy | 3 +-
.../select/test_mysql_varbinary_with_udf.groovy | 3 +-
.../select/test_oracle_all_types_select.groovy | 18 +
.../type_test/tvf/test_mysql_all_types_tvf.groovy | 3 +-
.../lakesoul/test_lakesoul_catalog.groovy | 52 -
.../lakesoul/test_lakesoul_filter.groovy | 74 -
.../paimon/test_paimon_catalog_varbinary.groovy | 97 +
.../paimon/test_paimon_system_table_auth.groovy | 191 ++
.../test_remote_doris_all_types_select.groovy | 172 ++
.../test_remote_doris_all_types_show.groovy | 168 ++
.../remote_doris/test_remote_doris_catalog.groovy | 68 +
.../remote_doris/test_remote_doris_predict.groovy | 150 ++
.../remote_doris/test_remote_doris_refresh.groovy | 128 ++
.../test_remote_doris_statistics.groovy | 105 ++
.../test_remote_doris_table_stats.groovy | 99 +
.../external_table_p0/tvf/test_backends_tvf.groovy | 10 +-
.../tvf/test_frontends_disks_tvf.groovy | 8 +-
.../tvf/test_frontends_tvf.groovy | 9 +-
.../tvf/test_s3_tvf_number_range.groovy | 16 +-
.../lakesoul/test_external_table_lakesoul.groovy | 72 -
.../azure_blob_all_test.groovy | 5 +-
.../hive_on_hms_and_dlf.groovy | 113 ++
.../iceberg_on_hms_and_filesystem_and_dlf.groovy | 103 +-
.../test_load_back_pressure_version.groovy | 46 +
.../function_p0/time/test_time_function.groovy | 110 ++
.../insert_overwrite_auto_detect.groovy | 6 +-
.../test_iot_overwrite_and_create.groovy | 10 +-
.../insert_p0/test_error_msg_truncate.groovy | 150 ++
.../suites/insert_p0/test_insert_docs_demo.groovy | 2 +-
...ommit_http_stream_lineitem_schema_change.groovy | 2 +
...ommit_stream_load_lineitem_schema_change.groovy | 2 +
.../test_ip_cidr_search_with_inverted_index.groovy | 4 +-
.../jsonb_p0/test_jsonb_predict_is_null.groovy | 5 +
.../broker_load/test_s3_load_with_set.groovy | 21 +-
.../insert/test_insert_rpc_order_problem.groovy | 114 ++
.../load_p0/merge_into/test_merge_into.groovy | 254 +++
.../load_p0/spark_load/test_spark_load.groovy | 150 --
.../stream_load/load_json_with_jsonpath.groovy | 87 +-
.../stream_load/test_stream_load_with_set.groovy | 15 +-
.../test_tvf_strict_mode_and_filter_ratio.groovy | 2 +-
.../suites/manager/test_manager_interface_3.groovy | 9 +-
.../test_base_add_col_multi_level_mtmv.groovy | 8 +-
..._base_alter_col_comment_multi_level_mtmv.groovy | 8 +-
...est_base_alter_col_type_multi_level_mtmv.groovy | 8 +-
.../test_base_comment_multi_level_mtmv.groovy | 8 +-
.../test_base_drop_col_multi_level_mtmv.groovy | 8 +-
.../mtmv_p0/test_base_drop_multi_level_mtmv.groovy | 8 +-
.../suites/mtmv_p0/test_base_mtmv.groovy | 30 +-
...v.groovy => test_base_recreate_col_mtmv.groovy} | 56 +-
.../test_base_recreate_on_commit_mtmv.groovy | 4 +-
.../test_base_rename_col_multi_level_mtmv.groovy | 8 +-
.../test_base_rename_multi_level_mtmv.groovy | 8 +-
.../test_base_rename_mv_multi_level_mtmv.groovy | 8 +-
.../mtmv_p0/test_base_rename_on_commit_mtmv.groovy | 6 +-
.../test_base_rename_p_mv_multi_level_mtmv.groovy | 8 +-
.../test_base_replace_multi_level_mtmv.groovy | 24 +-
.../test_base_replace_mv_multi_level_mtmv.groovy | 20 +-
.../test_base_replace_on_commit_mtmv.groovy | 4 +-
.../suites/mtmv_p0/test_build_mtmv.groovy | 15 -
.../mtmv_p0/test_create_mtmv_with_view.groovy | 112 ++
.../test_create_mtmv_with_view_alter.groovy | 94 +
.../test_create_mtmv_with_view_alter_table.groovy | 103 ++
...vy => test_create_mtmv_with_view_commit.groovy} | 61 +-
...roovy => test_create_mtmv_with_view_cte.groovy} | 68 +-
.../mtmv_p0/test_create_mtmv_with_view_mtmv.groovy | 126 ++
.../mtmv_p0/test_create_mtmv_with_view_pct.groovy | 103 ++
.../test_create_mtmv_with_view_rollup.groovy | 81 +
.../suites/mtmv_p0/test_hive_mtmv.groovy | 12 +
.../suites/mtmv_p0/test_hive_pct_mtmv.groovy | 161 ++
.../mtmv_p0/test_limit_partition_view_mtmv.groovy | 254 +++
.../suites/mtmv_p0/test_multi_pct_bad_mtmv.groovy | 377 ++++
.../suites/mtmv_p0/test_multi_pct_list_mtmv.groovy | 152 ++
.../suites/mtmv_p0/test_multi_pct_mtmv.groovy | 202 +++
.../mtmv_p0/test_multi_pct_nested_mtmv.groovy | 204 +++
.../test_multi_pct_null_partition_mtmv.groovy | 121 ++
.../mtmv_p0/test_multi_pct_rollup_mtmv.groovy | 124 ++
.../mtmv_p0/test_multi_pct_union_list_mtmv.groovy | 118 ++
.../mtmv_p0/test_multi_pct_union_mtmv.groovy | 119 ++
.../suites/mtmv_p0/test_multi_pct_view_mtmv.groovy | 159 ++
.../suites/mtmv_p0/test_null_multi_pct_mtmv.groovy | 231 +++
.../mtmv_p0/test_partition_refresh_mtmv.groovy | 15 +-
...hive_mtmv.groovy => test_view_hive_mtmv.groovy} | 42 +-
.../suites/mtmv_up_down_multi_pct_p0/load.groovy | 76 +
.../test_upgrade_downgrade_multi_pct_mtmv.groovy | 62 +
.../query_in_different_db.groovy | 5 +-
.../test_uniq_mv_useless.groovy | 16 +
.../nereids_function_p0/scalar_function/S.groovy | 3 +
.../explain/test_pushdown_explain.groovy | 84 +
.../test_date_function_v2.groovy | 58 +-
.../update/update_after_create_rollup.groovy | 164 ++
.../cross_join_list_str_increment_create.groovy | 8 +-
.../cross_join_range_date_increment_create.groovy | 8 +-
...cross_join_range_number_increment_create.groovy | 7 +-
.../inner_join_list_str_increment_create.groovy | 14 +-
.../inner_join_range_date_increment_create.groovy | 16 +-
...inner_join_range_number_increment_create.groovy | 12 +-
...left_anti_join_list_str_increment_create.groovy | 8 +-
...ft_anti_join_range_date_increment_create.groovy | 6 +-
..._anti_join_range_number_increment_create.groovy | 9 +-
.../left_join_list_str_increment_create.groovy | 8 +-
.../left_join_range_date_increment_create.groovy | 8 +-
.../left_join_range_number_increment_create.groovy | 6 +-
...left_semi_join_list_str_increment_create.groovy | 8 +-
...ft_semi_join_range_date_increment_create.groovy | 8 +-
..._semi_join_range_number_increment_create.groovy | 9 +-
.../self_conn_list_str_increment_create.groovy | 9 +-
.../self_conn_range_date_increment_create.groovy | 8 +-
.../self_conn_range_number_increment_create.groovy | 8 +-
.../join_elim_line_pattern.groovy | 558 ++++++
.../join_elim_star_pattern.groovy | 592 ++++++
.../nereids_rules_p0/mv/limit/limit_rewrite.groovy | 663 +++++++
.../mv/nested/nested_materialized_view.groovy | 4 +-
.../mv/nested_mtmv/nested_mtmv.groovy | 85 +
.../multi_trace_partition_mv_rewrite.groovy | 426 +++++
.../mv/pre_rewrite/limit/query_with_limit.groovy | 247 ++-
.../nereids_rules_p0/mv/topN/topN_rewrite.groovy | 690 +++++++
.../nereids_rules_p0/mv/tpch/mv_tpch_test.groovy | 15 +-
.../partition_prune/hive_partition_prune.groovy | 2 +-
.../partition_prune/list_prune_predicate.groovy | 367 ++++
.../suites/nereids_syntax_p0/advance_mv.groovy | 46 +-
.../nereids_syntax_p0/lag_lead_signature.groovy | 31 +-
.../mv/newMv/aggHaveDupBase.groovy | 9 +-
.../nereids_syntax_p0/mv/newMv/case_ignore.groovy | 7 +-
.../mv/newMv/dup_gb_mv_abs.groovy | 5 +-
.../mv/newMv/dup_gb_mv_plus.groovy | 6 +-
.../nereids_syntax_p0/mv/newMv/dup_mv_abs.groovy | 5 +-
.../nereids_syntax_p0/mv/newMv/dup_mv_bin.groovy | 5 +-
.../mv/newMv/dup_mv_bm_hash.groovy | 6 +-
.../nereids_syntax_p0/mv/newMv/dup_mv_plus.groovy | 5 +-
.../nereids_syntax_p0/mv/newMv/dup_mv_year.groovy | 4 +-
.../nereids_syntax_p0/mv/newMv/multi_slot1.groovy | 5 +-
.../nereids_syntax_p0/mv/newMv/multi_slot2.groovy | 5 +-
.../nereids_syntax_p0/mv/newMv/multi_slot3.groovy | 6 +-
.../nereids_syntax_p0/mv/newMv/multi_slot4.groovy | 6 +-
.../nereids_syntax_p0/mv/newMv/multi_slot5.groovy | 6 +-
.../nereids_syntax_p0/mv/newMv/multi_slot6.groovy | 6 +-
.../nereids_syntax_p0/mv/newMv/mv_with_view.groovy | 5 +-
.../nereids_syntax_p0/mv/newMv/rollback1.groovy | 6 +-
.../nereids_syntax_p0/mv/newMv/single_slot.groovy | 6 +-
.../mv/newMv/sum_devide_count.groovy | 6 +-
.../nereids_syntax_p0/mv/newMv/unique_mv.groovy | 4 +-
.../nereids_syntax_p0/mv/ut/MVMultiUsage.groovy | 1 +
.../suites/nereids_syntax_p0/mv/ut/MVWithAs.groovy | 6 +-
.../nereids_syntax_p0/mv/ut/aggMVCalcAggFun.groovy | 6 +-
.../nereids_syntax_p0/mv/ut/aggOnAggMV1.groovy | 6 +-
.../nereids_syntax_p0/mv/ut/aggOnAggMV10.groovy | 2 +
.../nereids_syntax_p0/mv/ut/aggOnAggMV11.groovy | 6 +-
.../nereids_syntax_p0/mv/ut/aggOnAggMV2.groovy | 6 +-
.../nereids_syntax_p0/mv/ut/aggOnAggMV3.groovy | 6 +-
.../nereids_syntax_p0/mv/ut/aggOnAggMV5.groovy | 5 +-
.../nereids_syntax_p0/mv/ut/aggOnAggMV6.groovy | 6 +-
.../nereids_syntax_p0/mv/ut/aggOnAggMV7.groovy | 6 +-
.../nereids_syntax_p0/mv/ut/bitmapUnionIn.groovy | 6 +-
.../nereids_syntax_p0/mv/ut/distinctQuery.groovy | 6 +-
.../nereids_syntax_p0/mv/ut/incMVReInSub.groovy | 6 +-
.../nereids_syntax_p0/mv/ut/incRewriteCD.groovy | 7 +-
.../mv/ut/joinOnCalcToJoin.groovy | 8 +-
.../mv/ut/joinOnLeftPToJoin.groovy | 9 +-
.../suites/nereids_syntax_p0/mv/ut/onStar.groovy | 6 +-
.../nereids_syntax_p0/mv/ut/onlyGroupBy.groovy | 5 +-
.../nereids_syntax_p0/mv/ut/orderByOnPView.groovy | 6 +-
.../nereids_syntax_p0/mv/ut/projectMV1.groovy | 6 +-
.../nereids_syntax_p0/mv/ut/projectMV2.groovy | 6 +-
.../nereids_syntax_p0/mv/ut/projectMV3.groovy | 5 +-
.../nereids_syntax_p0/mv/ut/projectMV4.groovy | 6 +-
.../suites/nereids_syntax_p0/mv/ut/subQuery.groovy | 6 +-
.../suites/nereids_syntax_p0/mv/ut/unionDis.groovy | 6 +-
.../nereids_syntax_p0/mv/where/k123/k123.groovy | 11 +
.../nereids_syntax_p0/test_cast_datetime.groovy | 8 -
.../test_auto_partition_behavior.groovy | 2 +-
...uto_partition_with_single_replica_insert.groovy | 78 -
.../test_list_partition_datatype.groovy | 2 +-
.../test_multi_column_partition.groovy | 2 +-
.../binary_functions/test_binary_function.groovy | 5 +-
.../test_binary_hex_function.groovy | 4 +
.../datetime_functions/test_date_function.groovy | 86 +-
.../test_binary_for_digest.groovy | 19 +-
..._materialized_view_common_expr_push_down.groovy | 76 +
.../test_non_overlap_seg_heavy_sc.groovy | 52 +-
.../suites/temp_table_p0/test_temp_table.groovy | 6 +-
regression-test/suites/variant_p2/load.groovy | 4 +-
.../create/test_create_vault_with_kerberos.groovy | 2 +-
run-be-ut.sh | 7 +-
thirdparty/download-thirdparty.sh | 5 +-
thirdparty/patches/cctz-lookup-offset.patch | 172 ++
thirdparty/vars.sh | 8 +-
tools/fdb/fdb_ctl.sh | 5 +-
1387 files changed, 48700 insertions(+), 12135 deletions(-)
create mode 100644 be/src/io/cache/peer_file_cache_reader.cpp
create mode 100644 be/src/io/cache/peer_file_cache_reader.h
rename
fe/fe-core/src/main/java/org/apache/doris/statistics/ExchangeStatsDerive.java
=> be/src/olap/rowset/segment_v2/inverted_index_common.cpp (61%)
create mode 100644 be/src/olap/rowset/segment_v2/inverted_index_common_impl.h
create mode 100644 be/src/pipeline/exec/blackhole_sink_operator.cpp
create mode 100644 be/src/pipeline/exec/blackhole_sink_operator.h
create mode 100644 be/src/vec/exec/format/table/remote_doris_reader.cpp
create mode 100644 be/src/vec/exec/format/table/remote_doris_reader.h
create mode 100644 be/src/vec/exprs/lambda_function/varray_sort_function.cpp
delete mode 100644
be/src/vec/functions/function_date_or_datetime_computation_v2.cpp
create mode 100644 be/test/exec/test_data/parquet_scanner/test_uuid.parquet
create mode 100644 be/test/geo/wkb_parse_test.cpp
create mode 100644 be/test/io/client/s3_file_system_test.cpp
create mode 100644 be/test/olap/rowset/segment_v2/segment_corruption_test.cpp
delete mode 100644 be/test/scan/mock_scanner_scheduler.h
create mode 100644 be/test/vec/data_types/serde/data_type_serde_map_test.cpp
create mode 100644 be/test/vec/data_types/serde/data_type_serde_struct_test.cpp
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/create_preinstalled_scripts/run83.hql
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/bucket-0/data-01367323-fe57-4cf2-8d63-658136eef42a-0.parquet
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/bucket-0/data-6a7f405a-2ffe-4c8d-97b8-5a9f69a497c6-0.parquet
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/bucket-0/data-f52a6587-0fcb-4d15-895d-6be35077eb8d-0.parquet
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/index/index-86b1c133-2b65-48d2-97b5-1c311f4c32b3-0
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/index/index-b00cbd60-d07f-462c-9ddc-effcf2ba6377-0
copy
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/{auto_bucket/index/index-da673059-ffd4-41e6-9525-20581001517c-0
=> binary_demo3/index/index-f6d8156c-7d1e-4643-beb4-f1040d4a8b71-0} (100%)
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/manifest/index-manifest-044381f8-72c7-4bbe-b3e9-d4829b7dc2c7-0
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/manifest/index-manifest-a5543fe0-8526-4707-83bb-4a46bae33d32-0
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/manifest/index-manifest-e5878ae9-97ff-4d9d-9e16-3601ef09cc9b-0
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/manifest/manifest-0f70c85a-f753-4ee3-b9dd-e81dd513ee3c-0
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/manifest/manifest-84997273-d8aa-452d-95b6-42c88639a8ce-0
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/manifest/manifest-f4bb99cc-ede0-4196-8a93-3685e67fa218-0
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/manifest/manifest-list-21d352ee-7901-4ca3-af30-dd0e43bedcb9-0
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/manifest/manifest-list-21d352ee-7901-4ca3-af30-dd0e43bedcb9-1
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/manifest/manifest-list-3dfd6008-44c0-4227-8a3f-cf4c96419518-0
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/manifest/manifest-list-3dfd6008-44c0-4227-8a3f-cf4c96419518-1
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/manifest/manifest-list-9a34dd3e-af29-4b67-81c4-db2d00637a41-0
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/manifest/manifest-list-9a34dd3e-af29-4b67-81c4-db2d00637a41-1
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/schema/schema-0
copy
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/{append_table =>
binary_demo3}/snapshot/EARLIEST (100%)
copy
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/{complex_all =>
binary_demo3}/snapshot/LATEST (100%)
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/snapshot/snapshot-1
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/snapshot/snapshot-2
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_demo3/snapshot/snapshot-3
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_size_test/bucket-0/data-5e407798-98e4-47e9-b884-ce798c662f92-0.parquet
copy
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/{auto_bucket/index/index-da673059-ffd4-41e6-9525-20581001517c-0
=> binary_size_test/index/index-5913b702-bb8d-4e33-b764-78c42470e82b-0} (100%)
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_size_test/manifest/index-manifest-3369567e-e644-447e-8c91-2feb5ef9079b-0
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_size_test/manifest/manifest-8b25f42e-072c-4ccb-8ebf-e5faf2c65f03-0
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_size_test/manifest/manifest-list-1a56808b-dfe6-4f71-a3c3-49d8b428ca8d-0
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_size_test/manifest/manifest-list-1a56808b-dfe6-4f71-a3c3-49d8b428ca8d-1
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_size_test/schema/schema-0
copy
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/{append_table =>
binary_size_test}/snapshot/EARLIEST (100%)
copy
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/{all_table_with_parquet
=> binary_size_test}/snapshot/LATEST (100%)
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/binary_size_test/snapshot/snapshot-1
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/create_preinstalled_scripts/iceberg/run21.sql
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/create_preinstalled_scripts/iceberg/run22.sql
create mode 100644 fe/be-java-extensions/hadoop-deps/pom.xml
rename fe/be-java-extensions/java-common/src/main/resources/{log4j.properties
=> log4j2.properties} (53%)
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/catalog/ColumnStats.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/doris/RemoteDorisCompatibleRestClient.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/doris/RemoteDorisExternalCatalog.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/doris/RemoteDorisExternalDatabase.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/doris/RemoteDorisExternalTable.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/doris/RemoteDorisRestClient.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/doris/source/RemoteDorisScanNode.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/doris/source/RemoteDorisSource.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/doris/source/RemoteDorisSplit.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergNereidsUtils.java
rename
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/action/{IcebergOptimizeActionFactory.java
=> IcebergExecuteActionFactory.java} (84%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/rewrite/RewriteDataFileExecutor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/rewrite/RewriteDataFilePlanner.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/rewrite/RewriteDataGroup.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/rewrite/RewriteGroupTask.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/rewrite/RewriteResult.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/constants/RemoteDorisProperties.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/deploy/impl/AmbariDeployManager.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/deploy/impl/K8sDeployManager.java
rename
fe/fe-core/src/main/java/org/apache/doris/{statistics/AssertNumRowsStatsDerive.java
=> httpv2/rest/response/GsonSchemaResponse.java} (76%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/BaseColInfo.java
copy fe/fe-core/src/main/java/org/apache/doris/mtmv/{MTMVBaseVersions.java =>
MTMVAnalyzeQueryInfo.java} (51%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVRelatedPartitionDescTransferGenerator.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/analyzer/UnboundBlackholeSink.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/AbstractMaterializedViewLimitOrTopNRule.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewLimitAggregateRule.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewLimitJoinRule.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewLimitScanRule.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewTopNAggregateRule.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewTopNJoinRule.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewTopNScanRule.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/PartitionIncrementMaintainer.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/RelatedTableInfo.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalBlackholeSinkToPhysicalBlackholeSink.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/PropagateNullableOnDateOrTimeLikeV2Args.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{MinutesAdd.java
=> AddTime.java} (68%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{Year.java
=> Century.java} (79%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{MinutesAdd.java
=> SubTime.java} (68%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/literal/format/TimeChecker.java
rename
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/{OptimizeTableCommand.java
=> ExecuteActionCommand.java} (56%)
rename
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/{optimize/BaseOptimizeAction.java
=> execute/BaseExecuteAction.java} (95%)
rename
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/{optimize/OptimizeAction.java
=> execute/ExecuteAction.java} (88%)
rename
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/{optimize/OptimizeActionFactory.java
=> execute/ExecuteActionFactory.java} (75%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/{DictionaryInsertExecutor.java
=> BlackholeInsertExecutor.java} (60%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/IcebergRewriteExecutor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/RewriteTableCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/WarmupSelectCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/merge/MergeIntoCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/merge/MergeMatchedClause.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/merge/MergeNotMatchedClause.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalBlackholeSink.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalBlackholeSink.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/BlackholeSink.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/AggStatsDerive.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/AnalyticEvalStatsDerive.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/BaseStatsDerive.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/DeriveFactory.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/EmptySetStatsDerive.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/HashJoinStatsDerive.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/MysqlStatsDerive.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/NestedLoopJoinStatsDerive.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/OlapScanStatsDerive.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/SelectStatsDerive.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/StatsRecursiveDerive.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/TableFunctionStatsDerive.java
copy
fe/fe-core/src/test/java/org/apache/doris/{datasource/paimon/PaimonUtilTest.java
=> blockrule/SqlBlockRuleMgrTest.java} (50%)
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/ColumnStatTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/doris/RemoteDorisCompatibleRestClientTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/doris/RemoteDorisRestClientTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/iceberg/IcebergNereidsUtilsTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/iceberg/rewrite/RewriteDataFilePlannerTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/deploy/AmbariDeployManagerTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/deploy/K8sDeployManagerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVRelatedPartitionDescGeneratorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVRelationTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVSchemaChangeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/exploration/mv/PartitionColumnTraceTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/PartitionPrunerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/literal/format/TimeCheckerTest.java
copy
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/{copier/LogicalPlanDeepCopierTest.java
=> plans/commands/UseCloudClusterCommandTest.java} (52%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertUtilsTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/merge/MergeIntoCommandTest.java
create mode 100644
regression-test/data/correctness_p0/test_function_signature_all_types.out
create mode 100644
regression-test/data/datatype_p0/json/json_group_by_and_distinct.out
create mode 100644
regression-test/data/external_table_p0/hive/test_hive_varbinary_type.out
rename
regression-test/data/external_table_p0/iceberg/action/{test_iceberg_optimize_actions.out
=> test_iceberg_execute_actions.out} (96%)
create mode 100644
regression-test/data/external_table_p0/iceberg/action/test_iceberg_rewrite_data_files.out
create mode 100644
regression-test/data/external_table_p0/iceberg/action/test_iceberg_rewrite_data_files_where_conditions.out
create mode 100644
regression-test/data/external_table_p0/iceberg/test_iceberg_varbinary.out
delete mode 100644
regression-test/data/external_table_p0/lakesoul/test_lakesoul_filter.out
create mode 100644
regression-test/data/external_table_p0/paimon/test_paimon_catalog_varbinary.out
create mode 100644
regression-test/data/external_table_p0/remote_doris/test_remote_doris_all_types_select.out
create mode 100644
regression-test/data/external_table_p0/remote_doris/test_remote_doris_all_types_show.out
create mode 100644
regression-test/data/external_table_p0/remote_doris/test_remote_doris_refresh.out
create mode 100644
regression-test/data/external_table_p0/remote_doris/test_remote_doris_statistics.out
copy regression-test/data/{schema_change_p0/test_non_overlap_seg_heavy_sc.out
=> function_p0/time/test_time_function.out} (86%)
create mode 100644 regression-test/data/function_p0/time/test_time_to_sec.csv
create mode 100644 regression-test/data/load_p0/merge_into/test_merge_into.out
delete mode 100644 regression-test/data/load_p0/spark_load/all_types1.txt
delete mode 100644 regression-test/data/load_p0/spark_load/all_types2.txt
delete mode 100644 regression-test/data/load_p0/spark_load/test_spark_load.out
create mode 100644
regression-test/data/load_p0/stream_load/test_load_with_jsonpath2.json
create mode 100644 regression-test/data/mtmv_p0/test_base_recreate_col_mtmv.out
create mode 100644 regression-test/data/mtmv_p0/test_create_mtmv_with_view.out
create mode 100644
regression-test/data/mtmv_p0/test_create_mtmv_with_view_alter.out
create mode 100644
regression-test/data/mtmv_p0/test_create_mtmv_with_view_alter_table.out
copy regression-test/data/{schema_change_p0/test_non_overlap_seg_heavy_sc.out
=> mtmv_p0/test_create_mtmv_with_view_commit.out} (64%)
copy regression-test/data/{schema_change_p0/test_non_overlap_seg_heavy_sc.out
=> mtmv_p0/test_create_mtmv_with_view_cte.out} (63%)
create mode 100644
regression-test/data/mtmv_p0/test_create_mtmv_with_view_mtmv.out
create mode 100644
regression-test/data/mtmv_p0/test_create_mtmv_with_view_pct.out
create mode 100644
regression-test/data/mtmv_p0/test_create_mtmv_with_view_rollup.out
create mode 100644 regression-test/data/mtmv_p0/test_hive_pct_mtmv.out
copy regression-test/data/mtmv_p0/{test_limit_partition_mtmv.out =>
test_limit_partition_view_mtmv.out} (100%)
create mode 100644 regression-test/data/mtmv_p0/test_multi_pct_list_mtmv.out
create mode 100644 regression-test/data/mtmv_p0/test_multi_pct_mtmv.out
create mode 100644 regression-test/data/mtmv_p0/test_multi_pct_nested_mtmv.out
copy regression-test/data/{schema_change_p0/test_non_overlap_seg_heavy_sc.out
=> mtmv_p0/test_multi_pct_null_partition_mtmv.out} (78%)
create mode 100644 regression-test/data/mtmv_p0/test_multi_pct_rollup_mtmv.out
create mode 100644
regression-test/data/mtmv_p0/test_multi_pct_union_list_mtmv.out
create mode 100644 regression-test/data/mtmv_p0/test_multi_pct_union_mtmv.out
create mode 100644 regression-test/data/mtmv_p0/test_multi_pct_view_mtmv.out
create mode 100644 regression-test/data/mtmv_p0/test_null_multi_pct_mtmv.out
create mode 100644 regression-test/data/mtmv_p0/test_view_hive_mtmv.out
copy regression-test/data/{load_p0/stream_load/load_json_with_jsonpath.out =>
mtmv_up_down_multi_pct_p0/test_upgrade_downgrade_multi_pct_mtmv.out} (51%)
create mode 100644
regression-test/data/nereids_p0/update/update_after_create_rollup.out
create mode 100644
regression-test/data/nereids_rules_p0/mv/partition_union_rewrite/multi_trace_partition_mv_rewrite.out
create mode 100644
regression-test/data/nereids_rules_p0/mv/topN/topN_rewrite.out
create mode 100644
regression-test/data/nereids_rules_p0/partition_prune/list_prune_predicate.out
create mode 100644
regression-test/data/nereids_syntax_p0/lag_lead_signature.out
delete mode 100644
regression-test/data/partition_p0/auto_partition/test_auto_partition_with_single_replica_insert.csv
delete mode 100644
regression-test/data/partition_p0/auto_partition/test_auto_partition_with_single_replica_insert.out
copy regression-test/data/{schema_change_p0/test_non_overlap_seg_heavy_sc.out
=> rollup_p0/test_materialized_view_common_expr_push_down.out} (86%)
create mode 100644
regression-test/suites/cloud_p0/balance/test_balance_warm_up_use_peer_cache.groovy
create mode 100644
regression-test/suites/cloud_p0/balance/test_balance_warm_up_with_compaction_use_peer_cache.groovy
create mode 100644
regression-test/suites/cloud_p0/balance/test_expanding_node_balance.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/read_from_peer/test_read_from_peer.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/test_topn_broadcast.groovy
create mode 100644
regression-test/suites/cloud_p0/node_mgr/test_cloud_add_backend_heartbeat.groovy
create mode 100644
regression-test/suites/cloud_p0/warm_up_select/test_warmup_select.groovy
create mode 100644
regression-test/suites/correctness_p0/test_function_signature_all_types.groovy
create mode 100644
regression-test/suites/datatype_p0/json/json_group_by_and_distinct.groovy
create mode 100644
regression-test/suites/external_table_p0/cache/test_hive_warmup_select.groovy
create mode 100644
regression-test/suites/external_table_p0/hive/test_hive_varbinary_type.groovy
rename
regression-test/suites/external_table_p0/iceberg/action/{test_iceberg_optimize_actions.groovy
=> test_iceberg_execute_actions.groovy} (76%)
create mode 100644
regression-test/suites/external_table_p0/iceberg/action/test_iceberg_rewrite_data_files.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/action/test_iceberg_rewrite_data_files_expression_conversion.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/action/test_iceberg_rewrite_data_files_where_conditions.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/test_iceberg_sys_table_auth.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/test_iceberg_varbinary.groovy
delete mode 100644
regression-test/suites/external_table_p0/lakesoul/test_lakesoul_catalog.groovy
delete mode 100644
regression-test/suites/external_table_p0/lakesoul/test_lakesoul_filter.groovy
create mode 100644
regression-test/suites/external_table_p0/paimon/test_paimon_catalog_varbinary.groovy
create mode 100644
regression-test/suites/external_table_p0/paimon/test_paimon_system_table_auth.groovy
create mode 100644
regression-test/suites/external_table_p0/remote_doris/test_remote_doris_all_types_select.groovy
create mode 100644
regression-test/suites/external_table_p0/remote_doris/test_remote_doris_all_types_show.groovy
create mode 100644
regression-test/suites/external_table_p0/remote_doris/test_remote_doris_catalog.groovy
create mode 100644
regression-test/suites/external_table_p0/remote_doris/test_remote_doris_predict.groovy
create mode 100644
regression-test/suites/external_table_p0/remote_doris/test_remote_doris_refresh.groovy
create mode 100644
regression-test/suites/external_table_p0/remote_doris/test_remote_doris_statistics.groovy
create mode 100644
regression-test/suites/external_table_p0/remote_doris/test_remote_doris_table_stats.groovy
delete mode 100644
regression-test/suites/external_table_p2/lakesoul/test_external_table_lakesoul.groovy
create mode 100644
regression-test/suites/fault_injection_p0/test_load_back_pressure_version.groovy
create mode 100644
regression-test/suites/function_p0/time/test_time_function.groovy
create mode 100644
regression-test/suites/insert_p0/test_error_msg_truncate.groovy
create mode 100644
regression-test/suites/load_p0/insert/test_insert_rpc_order_problem.groovy
create mode 100644
regression-test/suites/load_p0/merge_into/test_merge_into.groovy
delete mode 100644
regression-test/suites/load_p0/spark_load/test_spark_load.groovy
copy regression-test/suites/mtmv_p0/{test_base_recreate_on_commit_mtmv.groovy
=> test_base_recreate_col_mtmv.groovy} (53%)
create mode 100644
regression-test/suites/mtmv_p0/test_create_mtmv_with_view.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_create_mtmv_with_view_alter.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_create_mtmv_with_view_alter_table.groovy
copy regression-test/suites/mtmv_p0/{test_base_recreate_on_commit_mtmv.groovy
=> test_create_mtmv_with_view_commit.groovy} (50%)
copy regression-test/suites/mtmv_p0/{test_base_recreate_on_commit_mtmv.groovy
=> test_create_mtmv_with_view_cte.groovy} (61%)
create mode 100644
regression-test/suites/mtmv_p0/test_create_mtmv_with_view_mtmv.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_create_mtmv_with_view_pct.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_create_mtmv_with_view_rollup.groovy
create mode 100644 regression-test/suites/mtmv_p0/test_hive_pct_mtmv.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_limit_partition_view_mtmv.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_multi_pct_bad_mtmv.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_multi_pct_list_mtmv.groovy
create mode 100644 regression-test/suites/mtmv_p0/test_multi_pct_mtmv.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_multi_pct_nested_mtmv.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_multi_pct_null_partition_mtmv.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_multi_pct_rollup_mtmv.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_multi_pct_union_list_mtmv.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_multi_pct_union_mtmv.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_multi_pct_view_mtmv.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_null_multi_pct_mtmv.groovy
copy regression-test/suites/mtmv_p0/{test_hive_mtmv.groovy =>
test_view_hive_mtmv.groovy} (75%)
create mode 100644 regression-test/suites/mtmv_up_down_multi_pct_p0/load.groovy
create mode 100644
regression-test/suites/mtmv_up_down_multi_pct_p0/test_upgrade_downgrade_multi_pct_mtmv.groovy
create mode 100644
regression-test/suites/nereids_p0/update/update_after_create_rollup.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/join_elim_p_f_key/join_elim_line_pattern.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/join_elim_p_f_key/join_elim_star_pattern.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/limit/limit_rewrite.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/partition_union_rewrite/multi_trace_partition_mv_rewrite.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/topN/topN_rewrite.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/partition_prune/list_prune_predicate.groovy
delete mode 100644
regression-test/suites/partition_p0/auto_partition/test_auto_partition_with_single_replica_insert.groovy
create mode 100644
regression-test/suites/rollup_p0/test_materialized_view_common_expr_push_down.groovy
create mode 100644 thirdparty/patches/cctz-lookup-offset.patch
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
