This is an automated email from the ASF dual-hosted git repository.
morningman pushed a change to branch branch-seq_rc_file
in repository https://gitbox.apache.org/repos/asf/doris.git
discard 69802005dcd [Feature](tvf) Support using tvf to read
sequence_file/rc_file in local/hdfs/s3 (#41080)
add 89cf8d3f9b0 [refactor](nereids)use nereids to implement
TableQueryPlanAction (#39627)
add 820c9accd9d [fix](nereids)let query be able to forwarded to master
(#40119)
add 7fdd0be4da0 [optimize](short circuit) avoid set cacheId when non
prepared execute (#40525)
add fe8905abffc [opt](partial update) Remove unnecessary lock and refactor
some code for partial update (#40062)
add 7a34ebbccdc [feature](array-func)support array_match_all/any (#40605)
add 7548ed692d1 [opt](nereids) add project under aggregate to enable
extract common sub expression (#40473)
add d6132bb73c2 [improvement](cloud) manage node via sql like non cloud
mode (#40264)
add 5eb3c608469 [Improment] Log fatal when compaction memtracker not
return zero (#40667)
add c71514dd406 [enhancement](cloud) clarify codes and make TTL expiration
work after abnormal cache type transition (#40226)
add d8f911e0746 [Fix]set workload group for load channel (#40749)
add 4466541c1b4 [fix](statistics)Fix drop stats log editlog bug. Catch
drop stats exception while truncate table. (#40738)
add 96c299e0d8e [Fix](cases) fix test_use_mv (#40753)
add 69b14b56a71 [Fix](cases) Make case success when meet expected error
(#40713)
add 7659de554ce [fix](Nereids) avoid bad cast when compute scale for round
(#40776)
add 23ccaa0f08d [fix](DCHECK) Fix the DCHECK failure when the query is
canceled. (#40276)
add e40275ae44a [Fix](parquet-reader) Fix parquet reader crash in
set_dict(). (#40643)
add 70922604242 [chore](test)Exclude Hive-related packages from
`java-udf-src`. (#40757)
add 61eb0de241e [fix](export) fix p2 tests of export (#40198)
add 7e4bd25bff4 [bugfix](hive)Handle exceptions when submitting tasks
fails to prevent dead loop (#40708)
add c2ca37dcfa0 [fix](restore) Fix atomic restore with exists replicas
(#40734)
add e1db9450ca2 [fix](memory) Allows to enable memory tracker accuracy
detection via Config (#40714)
add 3e65faba3e0 [Refactor](inverted index) add analyzer for inverted index
to unify analysis process (#40758)
add 0ed55402087 [Bug](conv) fix conv function parser string failure return
wrong result (#40530)
add 6dada7fad31 [feature](array_agg) support array_agg with param is
array/map/struct (#40697)
add 72ce469570a [Bug](rpad) should check_chars_length avoid exceed
max_string_size in pad function (#40676)
add 3c8f9f7dad5 [fix](p0)Fix case timeout. (#40788)
add 3af0943c392 [fix](restore) Fix clean restore with view (#40620)
add 18a374f63c8 [fix](mtmv) Fix partition trace wrong when partition name
is same from both side of join (#40485)
add 55d6d6452f7 [Fix](nereids) set all nullable aggregate function to
alwaysnullable in window expression (#40693)
add 3cefe4817f4 [chore](CI)Sonar build should use JDK 17 (#40807)
add ffa96082221 [Refactor](Nereids) refactor fold constant framework on fe
(#40772)
add 10ba034c1f6 [fix](jdbc catalog) Fixed FE memory leak by enabling weak
references in HikariCP (#40773)
add 5479e62f984 [test](planner) fix generated column delete cases (#40706)
add 390e3333154 [Enhancement](delete) Modify some p2 delete cases'
property (#37689)
add f5a20378181 [Chore](function) check nested function on
AggregateFunctionNullBaseInline (#40748)
add b49e0256492 [feature](api) add BE HTTP /api/load_channels (#40645)
add 6c995e94cb9 [fix](encrypt) wrong mode arg of encrypt and decrypt
function make BE crash (#40726)
add 1d2d82a08c8 [case](fix) adjust data download url about hive docker
(#40805)
add a953a51a143 [Fix](Column) refactor ColumnNullable to provide flags
safety (#40769)
add 29fc07fd589 [Enhancement](profile) Add some details timer to
MergedProfile in OlapTableSinkOperator (#40832)
add d4a9915ee73 [fix](regression-test) Fix failed
adaptive_pipeline_task_serial_read_on_limit (#40711)
add 7831e8c0cb3 [improve](percentile_approx) use pdqsort to improve
percentile_approx function performance (#40096)
add fed90087a93 [fix](regression) fix some group commit and txn load case
(#40712)
add ef2f6e1ebb9 [improve](restore) Disable alter ops during atomic restore
(#40817)
add e986003275a [opt](profile) Add profile_manager_gc_interval_seconds on
fe.conf (#40596)
add aa5492cf097 [enhancement](test) Throw exception explicitly in forward
query test (#40742)
add ea98b199e46 [fix](regression-test) Add varchar column as distribution
key (#40791)
add 19e65c3bb6f [Bug](partition_topn) fix partition_topn not reset output
rows after do_partition_topn_sort (#40761)
add 28950d6b5cf [fix](auth)Http api check auth (#40688)
add 6a32d1e3271 [fix](cloud-mow) make cloud_txn_delete_bitmap_cache's
expired time more reasonable (#40333)
add 2a891a7f11a [enhancement](err-msg) Clarify error msg for forward
queries (#40802)
add 3bb0a2d9786 [minor](field) Occupy some field ID (#40858)
add 3cd6c4cb9c5 [opt](partial update) Allow to only specify key columns in
partial update (#40736)
add 700f25acfcf [Fix](regression) Fix flaky case
`test_delete_publish_skip_read` (#40782)
add 03ff755fefb [improvement](stream load) display the time of receiving
network data (#40735)
add c8fb96e97f6 [fix](statistics)Fix empty table keep auto analyze bug.
(#40811)
add 10d9c503c7f [fix](routine load) write edit log when rescheduled job
(#40728)
add 99290c91cb7 [enhancement](regression-test) agg schema value modify
case4 (#39404)
add 9dace0ed53c [Enhancement](test) Support test DecimalV3 types in be-ut
(#40830)
add c226d9f46ef [fix](window_funnel) fix wrong result of fixed mode
(#40459)
add 01c1b15f6a9 [enhancement](regression-test) agg schema value modify
case1 (#39390)
add 0a2fdcee62e [PipelineX](improvement) Prepare tasks in parallel (#40844)
add 2ceccace813 [Fix](cloud) Fix cluster status inconsistent with bes and
add config disable auto (#40799)
add ea708d9bafb [fix](cluster key) fix mow cluster key with schema change
(#40372)
add a49beb2c259 [Fix](regression test) Fix schema change concurrent with
txn regression case (#40765)
add 0f0fdc75cf7 [Enhancement](test) Add function test templates (#40462)
add 0cff2257291 [Enhancement](brpc)Added enable_brpc_builtin_services
parameter in be.conf (#40718)
add eae9e95b1b5 [chore](enhance) Added order by create_time for show
routine load (#40783)
add 279e4f91076 [test](p2) print error message when assert fails (#40699)
add a39d2ff4848 [fix](stream-load) catch exception when parsing
CONTENT_LENGTH (#40796)
add c81f73f4d32 [chore](github)Update CODEOWNERS (#40686)
add 8fe3a363c51 [fix](test) fix unstable case of partitions (#40861)
add 8c0789e061d [Chore](case) move slow case to p1 (#40860)
add b92b63e1537 Revert "[fix](scanner) Fix incorrect _max_thread_num in
scanner context" (#40804)
add b58570a34a1 [fix](memory) Refactor MemCounter (#40542)
add 2ae4ff86439 [opt](function) Optimize the concat(col, constant,
constant, constant) function (#40670)
add 8c97aa16296 [Bug](exchange) fix tablet sink shuffle without project
not match the output tuple (#40299)
add 5c9ac9aaf62 [improvement](statistics)User admin instead of root to run
stats sql. (#40867)
add 1501597e45f [Fix](Nereids) fix append_trailing_char_if_absent function
return null (#40820)
add 32d4b08989a [opt](function) optimize from_unixtime/date_format by
specially format str (#40821)
add 1f3313795f3 [fix](restore) Fix view name in atomic restore (#40876)
add a3295d781f9 [feature](view) support create or replace view stmt
(#40715)
add d5133be4b8e [Fix](orc-reader) Fix StringRef nullptr data in
orc-reader. (#40857)
add da692509343 [Enhancement]use awaitility.await() (#40112)
add a2d198ea7b7 [Fix](Variant) implement some interface in ColumnNothing
(#40607)
add 549196049a6 [bugfix](hive)Fix cache inconsistency issue (#40729)
add b39b24a3a15 [bugfix](hive)Remove redundant split operations (#40683)
add 64463f5f86a [fix](maxCompute)Fixed the bug that extra nulls are read
when reading maxcompute. (#40888)
add 4c212f157c5 [chore](variable) remove enable_nereids_planner flag
(#40743)
add 7cca2523fae [Chore][inverted index] remove duplicate null bitmap
reader in function array index (#40907)
add d5c24d348dd [fix](function) fix error result in split_by_string with
utf8 chars (#40710)
add 241cb7adf62 [bugfix](core) fmt lost one parameter (#40914)
add aa0d81d4449 [fix](compaction) catch exception in compaction (#40900)
add 810ccda3bf1 [Fix]Fix thread num not reset 0 when fetch failed (#40855)
add fdd7ddc1fe5 [improvement](mem)Dereference for executor (#40800)
add ef519c7ec64 [improve](cloud-mow) make the waiting time on
getDeleteBitmapUpdateLock more reasonable (#40341)
add 902cf1e913f [Fix](test)Fixing Kerberos Principal Not Mapping
Correctly to a Local User (#40905)
add ff05e1179e3 [bugfix](test)Set the enable_fallback_to_original_planner
behavior (#40913)
add 21b1c9a5743 [fix](config) enlarge batch size when insert cache hotspot
table (#40919)
add 4f3db874498 [fix](clucene) update clucene: fix CLStream memcpy read 1
extra byte (#240) (#40885)
add dda76f31a8d [Fix](partial update) Fix `__DORIS_SEQUENCE_COL__` is not
set for newly inserted rows in partial update (#40272)
add 0cd00fe571f [Fix](partial update) Fix partial update failed when
merge_type=MERGE (#40730)
add 538817ad6ab [improve](stack) do not report stack for -230 (#40716)
add cee07d62ce6 [fix](function) fix Substring/SubReplace error result with
input utf8 string (#40929)
add 83f899b32ba [enhancement](nereids)support subquery in LogicalGenerator
(#40663)
add 979cb012f88 [Featrue](default value) Support `bitmap_empty` default
value (#40364)
add 55727c312ea [Enhancement](function) support last_query_id function
(#40739)
add dc2579ffda2 [opt](partial update) Forbid partial update on
merge-on-write table with sync mv (#40190)
add 4a37b25b5c0 [Improvement](load) make load profile more real-time
(#40924)
add 60e310e5b82 [Feature](agg-state) support agg state storage
array/map/struct (#40582)
add 552cb345be8 [Refactor](scan) remove unless code in BE and FE (#40927)
add c5542f7c2f1 [chore](test) remove enable_nereids_planner=false (#40934)
add 7caa3b932ed [opt](nereids) enable runtime filter use cte as target
(#40815)
add 158f0b22356 [fix](table_options) fix potential NPE when quering
table_options sys table (#40944)
add adf7fb1f650 [Fix](load) Restrict the import of VARCHAR(0) data to
avoid coredump (#40940)
add eda303fef36 [enhancement](memtable) make memtable memusage more
accurate (#40912)
add 58a3abfeae7 [Fix](http)Ignore exceptions when getting system
information errors (#39671)
add 087f23a9726 [bugfix](cache) the cache capacity is wrong when memusage
> soft memlimit (#40961)
add a36f090e505 [fix](scan) Incorrect scan keys lead to wrong query
results. (#40814)
add 36b9528b8d8 [opt](routine load) optimize routine load timeout logic
(#40818)
add 2495d129f2d [Fix](scanner) lazy update block mem usage when status is
not ok (#40953)
add e4e137e852b [fix](regression)fix some regression test (#40928)
add b2a50a3eb78 [feature](functions) impl scalar functions translate and
url_encode (#40567)
add 91d085c8fe9 [enhance](mtmv) Refuse to execute insert overwrite on the
same table (#40558)
add 1da5de683c0 [enhance](mtmv)when drop temp partition, not trigger
materialized view refresh (#40875)
add 18048e24a26 [enhance](mtmv)tasks tvf not getLock (#40816)
add 412ff703174 [enhance](mtmv)Improve the speed of obtaining table
snapshots (#40717)
add ced6ec07326 [fix](restore) Set the storage medium of the bind replicas
(#40921)
add e15c1fe04c5 [test](inverted index) set enable_common_expr_pushdown
true for variant_github_events_p2 (#40957)
add 2aab21fc711 [opt](merge-on-write) Reduce the version not continuous
logs for merge-on-write table (#40946)
add f3d92e48ed7 [fix](mtmv) Generate mtmv cache should use ADMIN user, and
rewritten plan should not check privilege (#40374)
add 9986fa747ad [Chore](compatible) adjust register_alternative_function
(#40941)
add 929304502a1 [improve](cloud) use compute group instead of cluster and
remove cloud_instance_id (#40767)
add 722fabe0010 [Bug](compatibility) fix percentile function coredump when
upgrade (#39330)
add 23857346ae6 [fix](function)fix error result in replace_empty with utf8
chars (#40869)
add 80482c5fc4f [opt](nereids) clean count usage in ColumnStatistic during
stats deriving (#40654)
add 53fdd9ed51b [fix](cloud-mow) Add retry when calculating delete bitmap
timeout when loading data (#40562)
add 07a536226ef [Fix](table size) Fix MoW table merge data fault (#40880)
add 2a7ac748b1f [Fix](test) fix flake case in both
test_insert_strict_fail_url and test_insert_partition_fail_url (#40998)
add d513b11eb4e [feature](nereids)support correlated scalar subquery
without scalar agg (#39471)
add 99ef5236eaa [minor](refactor) Remove duplicate code (#40952)
add 8b154db1753 [fix](Nereids) fix fold constant by be return type
mismatched (#39723)
add d8277526697 [chore](test) remove enable_nereids_planner=false in cases
(#40984)
add 107856e83a6 [fix](restore) Ignore base tablet if it is migrated
(#41017)
add fc7f8f3c09a [fix](Nereids) merge request properties map of group
should compare cost (#40819)
add ed2ec7b460a [opt](nereids) show user friendly error msg when window
function contains order by expression (#40937)
add 17da0969ece [fix](tvf) fix that FE OOM when using tvf (#40981)
add 34ab55ff860 [improve](load) change memtable memory limiter policy
(#41018)
add c82165ee16d [feature](functions) impl scalar functions
normal_cdf,to_iso8601,from_iso8601_date (#40695)
add 04223de2eb4 [chore](test) remove enable_nereids_planner=false in cases
(#41035)
add 7a00dd4a4ac [Feature](json) Support json_search function (#40948)
add c55c72121c2 [opt](binlog) Support rename column binlog (#39782)
add 066de31fdae [Performance](exec) Add EOF status back in exchange
operator (#41011)
add 51ba957fd6b [improve](partition_topn) Add partition threshold check in
hash table to control partition nums (#39057)
add 11dfd19a331 [fix](window_func) fix bug of agg function used in window
function and add many test cases (#40678)
add 00be77e180e [improve](multi table) allow auto resume if plan load
fails (#40991)
add 61dc2580349 [bugfix](testcase) Set the
enable_fallback_to_original_planner behavior (#40989)
add 76818506d92 [improve](cloud-mow) merge and remove old version of
delete bitmap when cumulative compaction is done (#40204)
add acbf59625c3 [fix](profile) Fix npe when updating profile for internal
load task. (#40990)
add a2b9aa4d495 [fix](tvf) fix FE cannot start when replay `alter view
from tvf` (#40872)
add da6ac0c5f47 [test](mtmv) Fix regression test unstable (#40871)
add 252aeeb6cf5 [fix](mtmv) Fix duplicate column name not check when
create materialized view (#40658)
add d7e5d461157 [fix](mtmv) Fix compensate union all wrongly when query
rewrite by materialized view (#40803)
add 73daca7e63c [Bug](compatibility) fix covar_samp function coredump when
upgrade (#41023)
add 922bee25534 [fix](sys_table) fix potential NPE when query
table_properties and partitions sys table (#40972)
add f23a594a843 [fix](cluster key) support cloud mode (#40593)
add 9a32c1519b2 [fix](cluster key) add delta writer be ut (#41013)
add 912dd80b9ab [Fix](regression) Fix flaky case
`test_partial_update_only_keys` (#41068)
add ba0a6a78d3e [fix](deploy) refine fdb_ctl.sh (#41070)
add b2a21e6533c [bugfix](external)Memory leak problem for external table
with insert operation (#40440)
add ebabec1d3e6 [fix](migrate) Copy binlog files (#41083)
add 7331481e460 [fix](trash) Fix `clean_trash` docker regression case
(#40925)
add cc444ee8a68 [Enhancement] Insert overwrite case need to keep old
partition data in recycle-bin (#40512)
add 69222f20794 [chore](log) Remove some unnecessary log (#40975)
add d348d839792 [fix](compile)fix mac compile : std no member numbers
error. (#41075)
add 6bceb32df4b [Fix](jdbc-scanner) Fix jdbc scanner memory leak because
it didn't close `outputTable`. (#41041)
add 63f957d0ccd [opt](index compaction)Avoid get file size when create
index reader and remove unnecessary file exists (#41079)
add 858b5305bd1 [Fix]unified cancel method in coordinator (#41038)
add 25c89346972 [refactor](profile report) Remove old profile reporting.
(#40185)
add cb2e915869d [refactor](opt) improve BE code readability of
multi_match_any function (#39354)
add b70faf76f8f [bugfix](allocatebytes) ignore null ptr column in Block
(#41093)
add cbe5f7e9ac8 [regression-test](feature) add skip non-concurrent test
functions (#41021)
add 81404014cae [Fix](topn) avoid missmatched row count when upgrading
(#41000)
add 5214e6b4bc8 [fix](Variant) check enable light_schema_change when
create table with variant type (#40908)
add 08f7787e413 [opt](cache elimation) using step decending method to
elimiate cache (#41086)
add 8c34bfea870 [fix](nereids)adjust conjunct's nullable info in
LogicalExternalRelation (#41014)
add eb7fd6e74b3 [fix](load) disable num segments check in compatibility
mode (#41053)
add 7c9c0e0b09b [feat](profile) Print changed session var in profile
(#41016)
add e01edcc48af [fix](test-case) fix unstable test case about
table_options sys table (#41006)
add f57dc9298a9 [Fix]Fix publish may wait timeout because of dead BE
(#40763)
add d4247afc0e6 [docker](fix) Modify docker be default storage path
(#40665)
add ddc5592d430 [feat](nereids) disable join reorder if any table row
count is not available (#40349)
add ab7e77f6ecb [fix](function) Hide secret key for aes_decrypt/encrypt in
result header (#39969)
add 1a2a1b7dfe7 [fix](cloud) fix error-prone and misleading codes in cache
warmup (#41087)
add e993b0fdec1 [fix](cloud) Fix incorrect log for detached tablet stats
kv (#41119)
add bb7c0644e14 [opt](load) check -238 segment number limit earlier
(#39045)
add ccd6e073d85 [fix](ci) trigger cloud_p0 if file cloud/CMakeLists.txt
changed (#41141)
add 7348e738b21 [enhancement](cloud) support BE http action:
/api/file_cache?op=hash (#40831)
add 48a22d2f956 [fix](restore) Fix view signature (#41120)
add c2e4d972a18 [Fix](inverted index) fix wrong opt for count_on_index
(#41127)
add 19424d59b3a [case](mtmv) Failed to fix the case of concurrent insert
overwrite execution (#41125)
add c38938d2067 [fix](nereids)modify split_part function to fold to null
literal with correct data type (#41109)
add 42077ddb49b [ci](cloud_p0)do not run nonConcurrent case to reduce
build time (#41111)
add ace2796f778 [fix](restore) only drop registered table when cancel
restore (#41146)
add 093939f0e05 [fix](external-p2) ignore external p2 cases (#41148)
add 008ddb2fae9 [fix](transaction) commit txn check txn status (#40064)
add d4c94325c91 [improve](cloud-mow) print the queue length of committing
txn on FE (#40340)
add fb9d85e0014 [bugfix](paimon)Get the file format by file name (#41020)
add 563c9ab80ee [fix](window function) Fix illegal frame range (#41147)
add e8812855dea [fix](migrate) Fix iterator returning too early (#41168)
add 8780498c1a9 [fix](test) fix test_jdbc_query_mysql sql87 (#41158)
add ed2a0607222 [Fix](compile) Cmakelist is not available for mac (#41098)
add dd5605ef157 [feat](Authorization-plugin)Authorization framework
modularization (#40750)
add fb40871b070 [fix](explain) fix NPE when explain verbose with partition
batch mode (#40969)
add f0e271763b4 [fix](catalog) should return error if try using a unknown
database (#40479)
add 601cc585f09 [fix](memory) Fix refresh cgroup meminfo (#41123)
add 839c44615ba [fix](build) Change the return type of `get_size` in
`tablet_meta` for MacOS compatibility. (#41140)
add 7a7bc6a7f73 [opt](nereids) refine expression estimation (#40698)
add 9ef26181478 [Bug](materialized-view) only throw 'MV same with base
table is useless' when addMVClause's Ke… (#41144)
add b0449d2ff93 [revert](storage) storage medium of partition should not
inherit from table (#41192)
add a722a102ab9 [improvement](nereids) Simplify ScanNode projection
handling by removing redundant conditions (#40801)
add 232170af61a [fix](Nereids) two cloud syntax different with legacy
planner (#41198)
add a6564b27442 [Feature](sink) support parallel outfile (#41039)
add cf2e8f859f7 [fix](cases) case break due to cluster -> compute group
(#41196)
add 0b92e5a7127 [improvement](statistics)Support cloud version set row
count to -1 when not reported. (#41015)
add 433e8c38950 [Improment]Add workload group query detail (#40050)
add 52bb7eb266b [feature](jdbc catalog) support gbase jdbc catalog (#41027)
add 16b61745dab [Feature](topn) change topn_filter_limit_threshold to
topn_filter_ratio (#41066)
add 4c124b8068a [feature](file cache) Support in-memory filecache for
no-disk/slow-disk system (#38811)
add 0e7f4f01b80 [fix](cloud) Optimize prompt messages when no cluster
(#38834)
add 370ddd8fb2e [feat](metatable) support table$partitions for hive table
(#40774)
add 47ce9f905e8 [fix](Nereids) simplify decimal comparison wrong when cast
to smaller scale (#41151)
add 990f18fc887 [Opt](limit) Avoid copy in set_num_rows implementation
(#41062)
new 580f38bc352 [Feature](tvf) Support using tvf to read
sequence_file/rc_file in local/hdfs/s3 (#41080)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (69802005dcd)
\
N -- N -- N refs/heads/branch-seq_rc_file (580f38bc352)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/CODEOWNERS | 1 +
.github/workflows/sonarcloud.yml | 4 +-
be/src/agent/be_exec_version_manager.cpp | 49 +-
be/src/agent/be_exec_version_manager.h | 21 +-
be/src/agent/heartbeat_server.cpp | 39 +
be/src/agent/task_worker_pool.cpp | 4 +-
be/src/cloud/cloud_base_compaction.cpp | 2 +-
be/src/cloud/cloud_cumulative_compaction.cpp | 87 +-
be/src/cloud/cloud_cumulative_compaction.h | 2 +
.../cloud/cloud_cumulative_compaction_policy.cpp | 7 +-
be/src/cloud/cloud_cumulative_compaction_policy.h | 5 +-
be/src/cloud/cloud_delete_bitmap_action.cpp | 127 ++
be/src/cloud/cloud_delete_bitmap_action.h | 54 +
.../cloud/cloud_engine_calc_delete_bitmap_task.cpp | 11 +-
be/src/cloud/cloud_meta_mgr.cpp | 53 +-
be/src/cloud/cloud_meta_mgr.h | 7 +
be/src/cloud/cloud_storage_engine.cpp | 26 +-
be/src/cloud/cloud_storage_engine.h | 25 +-
be/src/cloud/cloud_tablet.cpp | 33 +-
be/src/cloud/cloud_tablet.h | 2 +-
be/src/cloud/cloud_tablet_mgr.cpp | 2 +-
be/src/cloud/cloud_txn_delete_bitmap_cache.cpp | 42 +-
be/src/cloud/cloud_txn_delete_bitmap_cache.h | 10 +-
be/src/cloud/config.cpp | 15 +-
be/src/cloud/config.h | 16 +-
be/src/clucene | 2 +-
be/src/common/config.cpp | 37 +-
be/src/common/config.h | 34 +-
be/src/common/daemon.cpp | 16 +-
be/src/exec/olap_common.h | 6 +-
be/src/exec/rowid_fetcher.cpp | 4 +
be/src/exec/tablet_info.cpp | 4 +
be/src/exec/tablet_info.h | 3 +
be/src/exprs/runtime_filter.cpp | 1 +
be/src/http/action/file_cache_action.cpp | 18 +-
be/src/http/action/http_stream.cpp | 15 +-
be/src/http/action/load_channel_action.cpp | 66 +
be/src/http/action/load_channel_action.h | 43 +
be/src/http/action/stream_load.cpp | 15 +-
be/src/http/default_path_handlers.cpp | 9 +-
be/src/io/cache/block_file_cache.cpp | 88 +-
be/src/io/cache/block_file_cache.h | 13 +-
be/src/io/cache/block_file_cache_factory.cpp | 67 +-
be/src/io/cache/file_block.cpp | 40 +-
be/src/io/cache/file_block.h | 4 +-
be/src/io/cache/file_cache_common.cpp | 16 +-
be/src/io/cache/file_cache_common.h | 7 +-
be/src/io/cache/file_cache_storage.h | 23 +-
be/src/io/cache/fs_file_cache_storage.cpp | 277 ++-
be/src/io/cache/fs_file_cache_storage.h | 31 +-
be/src/io/cache/mem_file_cache_storage.cpp | 131 ++
be/src/io/cache/mem_file_cache_storage.h | 55 +
be/src/olap/compaction.cpp | 90 +-
be/src/olap/delta_writer_v2.cpp | 3 +-
be/src/olap/inverted_index_parser.h | 2 +
be/src/olap/memtable.cpp | 50 +-
be/src/olap/memtable.h | 37 +-
be/src/olap/memtable_flush_executor.cpp | 24 +-
be/src/olap/memtable_flush_executor.h | 4 +-
be/src/olap/memtable_memory_limiter.cpp | 176 +-
be/src/olap/memtable_memory_limiter.h | 13 +-
be/src/olap/memtable_writer.cpp | 53 +-
be/src/olap/memtable_writer.h | 11 +-
be/src/olap/merger.cpp | 56 +-
be/src/olap/merger.h | 3 +-
be/src/olap/options.cpp | 20 +-
be/src/olap/options.h | 7 +-
be/src/olap/page_cache.h | 26 +-
be/src/olap/partial_update_info.cpp | 52 +-
be/src/olap/partial_update_info.h | 10 +-
be/src/olap/rowset/beta_rowset_writer.cpp | 41 +-
be/src/olap/rowset/beta_rowset_writer.h | 5 +-
be/src/olap/rowset/rowset_meta.cpp | 1 +
be/src/olap/rowset/rowset_meta_manager.cpp | 63 +
be/src/olap/rowset/rowset_meta_manager.h | 3 +
be/src/olap/rowset/segcompaction.cpp | 4 +-
be/src/olap/rowset/segment_v2/column_reader.cpp | 18 +-
.../inverted_index/analyzer/analyzer.cpp | 118 +
.../segment_v2/inverted_index/analyzer/analyzer.h | 48 +
.../rowset/segment_v2/inverted_index_cache.cpp | 6 +-
.../olap/rowset/segment_v2/inverted_index_cache.h | 31 +-
.../rowset/segment_v2/inverted_index_reader.cpp | 136 +-
.../olap/rowset/segment_v2/inverted_index_reader.h | 16 -
.../rowset/segment_v2/inverted_index_writer.cpp | 105 +-
be/src/olap/rowset/segment_v2/segment.cpp | 2 +-
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 8 +-
be/src/olap/rowset/segment_v2/segment_writer.cpp | 215 +-
be/src/olap/rowset/segment_v2/segment_writer.h | 7 +
.../rowset/segment_v2/vertical_segment_writer.cpp | 200 +-
.../rowset/segment_v2/vertical_segment_writer.h | 7 +
be/src/olap/rowset_builder.cpp | 12 +-
be/src/olap/schema_cache.h | 7 +-
be/src/olap/schema_change.cpp | 4 +-
be/src/olap/segment_loader.cpp | 6 +-
be/src/olap/segment_loader.h | 11 +-
be/src/olap/snapshot_manager.cpp | 13 +-
be/src/olap/storage_engine.h | 8 +-
be/src/olap/tablet.cpp | 13 +-
be/src/olap/tablet.h | 1 +
be/src/olap/tablet_manager.cpp | 17 +-
be/src/olap/tablet_meta.cpp | 58 +
be/src/olap/tablet_meta.h | 27 +-
be/src/olap/tablet_schema.cpp | 2 +-
be/src/olap/tablet_schema.h | 1 +
be/src/olap/tablet_schema_cache.cpp | 4 +-
be/src/olap/tablet_schema_cache.h | 9 +-
be/src/olap/task/engine_publish_version_task.cpp | 26 +-
be/src/olap/task/engine_storage_migration_task.cpp | 102 +-
be/src/olap/task/engine_storage_migration_task.h | 5 +-
be/src/olap/txn_manager.h | 9 +-
be/src/olap/version_graph.cpp | 15 +-
be/src/pipeline/exec/analytic_source_operator.cpp | 4 +-
.../distinct_streaming_aggregation_operator.cpp | 8 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 29 +-
be/src/pipeline/exec/exchange_sink_operator.h | 5 +-
be/src/pipeline/exec/olap_scan_operator.cpp | 24 +-
.../pipeline/exec/partition_sort_sink_operator.cpp | 61 +-
.../pipeline/exec/partition_sort_sink_operator.h | 12 +-
.../exec/partition_sort_source_operator.cpp | 6 +-
be/src/pipeline/exec/result_file_sink_operator.cpp | 142 +-
be/src/pipeline/exec/result_file_sink_operator.h | 5 +-
be/src/pipeline/exec/scan_operator.cpp | 23 +-
be/src/pipeline/pipeline.h | 3 +-
be/src/pipeline/pipeline_fragment_context.cpp | 121 +-
be/src/pipeline/pipeline_fragment_context.h | 11 +-
be/src/pipeline/query_cache/query_cache.cpp | 5 +-
be/src/pipeline/query_cache/query_cache.h | 8 +-
be/src/runtime/exec_env.h | 9 +-
be/src/runtime/exec_env_init.cpp | 9 +-
be/src/runtime/fragment_mgr.cpp | 302 ++-
be/src/runtime/load_channel.cpp | 36 +-
be/src/runtime/load_channel.h | 3 +-
be/src/runtime/load_channel_mgr.cpp | 6 +-
be/src/runtime/load_channel_mgr.h | 19 +-
be/src/runtime/load_stream.cpp | 9 +-
be/src/runtime/load_stream.h | 2 +
be/src/runtime/memory/global_memory_arbitrator.cpp | 20 -
be/src/runtime/memory/global_memory_arbitrator.h | 19 +-
be/src/runtime/memory/lru_cache_policy.h | 153 +-
be/src/runtime/memory/lru_cache_value_base.h | 7 +-
be/src/runtime/memory/mem_counter.h | 95 +
be/src/runtime/memory/mem_tracker.cpp | 91 +-
be/src/runtime/memory/mem_tracker.h | 233 +-
be/src/runtime/memory/mem_tracker_limiter.cpp | 175 +-
be/src/runtime/memory/mem_tracker_limiter.h | 294 ++-
be/src/runtime/memory/thread_mem_tracker_mgr.cpp | 10 +-
be/src/runtime/memory/thread_mem_tracker_mgr.h | 21 +-
be/src/runtime/query_context.cpp | 9 +-
be/src/runtime/query_context.h | 2 -
.../routine_load/routine_load_task_executor.cpp | 2 +-
be/src/runtime/runtime_filter_mgr.cpp | 6 +-
be/src/runtime/runtime_query_statistics_mgr.cpp | 5 +-
be/src/runtime/runtime_state.h | 12 +
be/src/runtime/stream_load/stream_load_context.cpp | 2 +
be/src/runtime/tablets_channel.cpp | 2 +-
be/src/runtime/thread_context.h | 4 +
be/src/runtime/workload_group/workload_group.cpp | 16 +-
.../workload_group/workload_group_manager.cpp | 4 +-
be/src/service/brpc_service.cpp | 2 +
be/src/service/http_service.cpp | 11 +
be/src/service/point_query_executor.cpp | 10 +-
be/src/service/point_query_executor.h | 12 +-
be/src/util/algorithm_util.h | 55 +
be/src/util/doris_metrics.cpp | 2 +-
be/src/util/jsonb_document.h | 29 +
be/src/util/mem_info.cpp | 55 +-
be/src/util/obj_lru_cache.cpp | 6 +-
be/src/util/obj_lru_cache.h | 8 +-
be/src/util/ref_count_closure.h | 8 +-
be/src/util/stack_util.cpp | 6 +
be/src/util/tdigest.h | 7 +-
be/src/util/url_coding.cpp | 42 +-
be/src/util/url_coding.h | 12 +-
.../vec/aggregate_functions/aggregate_function.h | 3 -
.../aggregate_function_binary.h | 4 +-
.../aggregate_function_collect.cpp | 30 +-
.../aggregate_function_collect.h | 74 +-
.../aggregate_function_corr.cpp | 9 +
.../aggregate_function_covar.cpp | 8 +-
.../aggregate_functions/aggregate_function_covar.h | 49 +-
.../aggregate_function_distinct.h | 2 -
.../aggregate_function_foreach.h | 4 -
.../aggregate_function_group_array_intersect.h | 14 +-
.../aggregate_functions/aggregate_function_null.h | 9 +-
.../aggregate_function_orthogonal_bitmap.h | 40 +-
.../aggregate_function_percentile.cpp | 20 +-
.../aggregate_function_percentile.h | 8 +-
.../aggregate_function_percentile_approx.cpp | 11 +-
.../aggregate_function_simple_factory.h | 23 +-
.../aggregate_function_stddev.cpp | 14 +-
.../aggregate_functions/aggregate_function_uniq.h | 4 +
.../aggregate_function_uniq_distribute_key.h | 7 +
.../aggregate_function_window.h | 6 +-
.../aggregate_function_window_funnel.cpp | 6 +-
.../aggregate_function_window_funnel.h | 59 +-
be/src/vec/columns/column.h | 11 +-
be/src/vec/columns/column_decimal.cpp | 2 -
be/src/vec/columns/column_nothing.h | 7 +
be/src/vec/columns/column_nullable.cpp | 85 +-
be/src/vec/columns/column_nullable.h | 153 +-
be/src/vec/common/allocator.cpp | 2 -
be/src/vec/common/allocator.h | 19 +-
be/src/vec/common/sort/partition_sorter.cpp | 9 +-
be/src/vec/core/block.cpp | 12 +-
be/src/vec/core/types.h | 13 +-
be/src/vec/data_types/data_type_agg_state.h | 6 +-
be/src/vec/data_types/data_type_factory.cpp | 98 +-
be/src/vec/data_types/data_type_factory.hpp | 2 -
be/src/vec/exec/format/orc/vorc_reader.cpp | 42 +-
.../format/parquet/byte_array_dict_decoder.cpp | 3 +
.../format/parquet/fix_length_dict_decoder.hpp | 3 +
be/src/vec/exec/scan/scanner_context.cpp | 120 +-
be/src/vec/exec/scan/scanner_context.h | 9 +-
be/src/vec/exec/scan/scanner_scheduler.cpp | 6 +-
be/src/vec/exec/scan/vmeta_scanner.cpp | 170 +-
be/src/vec/exec/scan/vmeta_scanner.h | 2 +
be/src/vec/exprs/vmatch_predicate.cpp | 16 +-
be/src/vec/functions/array/function_array_index.h | 5 -
.../functions/array/function_array_register.cpp | 2 +
.../vec/functions/array/varray_match_function.cpp | 145 ++
be/src/vec/functions/date_format_type.h | 156 ++
be/src/vec/functions/date_time_transforms.h | 127 +-
be/src/vec/functions/function_conv.cpp | 9 +-
.../function_date_or_datetime_to_string.cpp | 5 +
.../functions/function_datetime_string_to_string.h | 140 +-
be/src/vec/functions/function_encryption.cpp | 9 +-
be/src/vec/functions/function_jsonb.cpp | 354 +++
be/src/vec/functions/function_string.cpp | 2 +
be/src/vec/functions/function_string.h | 664 ++++--
be/src/vec/functions/function_timestamp.cpp | 244 +-
be/src/vec/functions/function_tokenize.cpp | 26 +-
.../functions/functions_multi_string_search.cpp | 200 +-
be/src/vec/functions/like.cpp | 204 +-
be/src/vec/functions/like.h | 4 +
be/src/vec/functions/match.cpp | 68 +-
be/src/vec/functions/match.h | 7 +-
be/src/vec/functions/math.cpp | 74 +
be/src/vec/functions/simple_function_factory.h | 8 -
be/src/vec/olap/olap_data_convertor.cpp | 70 +-
be/src/vec/olap/olap_data_convertor.h | 15 +-
be/src/vec/runtime/vdata_stream_mgr.cpp | 6 +-
be/src/vec/sink/vdata_stream_sender.cpp | 16 +-
be/src/vec/sink/vdata_stream_sender.h | 5 +-
be/src/vec/sink/vtablet_block_convertor.cpp | 2 +-
be/src/vec/sink/writer/vtablet_writer.cpp | 16 +
be/src/vec/sink/writer/vtablet_writer.h | 2 +
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 15 +-
be/test/io/cache/block_file_cache_test.cpp | 1192 ++++++++--
be/test/io/fs/s3_file_writer_test.cpp | 4 +-
be/test/olap/delta_writer_cluster_key_test.cpp | 365 +++
be/test/olap/lru_cache_test.cpp | 12 +-
.../runtime/memory/thread_mem_tracker_mgr_test.cpp | 4 +-
be/test/util/algo_util_test.cpp | 46 +
.../column_nullable_seriazlization_test.cpp | 75 +-
be/test/vec/columns/column_nullable_test.cpp | 112 +
be/test/vec/columns/column_nullable_test.h | 105 +
be/test/vec/columns/column_resize_test.cpp | 1 -
be/test/vec/core/column_string_test.cpp | 12 +-
be/test/vec/core/column_test.cpp | 121 +
.../vec/function/function_array_element_test.cpp | 12 +-
be/test/vec/function/function_array_index_test.cpp | 20 +-
be/test/vec/function/function_math_test.cpp | 27 +-
be/test/vec/function/function_string_test.cpp | 71 +-
be/test/vec/function/function_test_template.cpp | 57 +
be/test/vec/function/function_test_util.cpp | 41 +-
be/test/vec/function/function_test_util.h | 29 +-
be/test/vec/function/table_function_test.cpp | 10 +-
build.sh | 3 +
cloud/CMakeLists.txt | 2 +-
cloud/src/common/bvars.cpp | 1 +
cloud/src/common/bvars.h | 1 +
cloud/src/meta-service/meta_service.cpp | 108 +-
cloud/src/meta-service/meta_service.h | 12 +
cloud/src/meta-service/meta_service_helper.h | 3 +
cloud/src/meta-service/meta_service_resource.cpp | 5 +-
.../src/meta-service/meta_service_tablet_stats.cpp | 20 +-
cloud/src/resource-manager/resource_manager.cpp | 4 +-
.../be/resource/be_disaggregated_entrypoint.sh | 3 +-
docker/runtime/doris-compose/cluster.py | 76 +-
docker/runtime/doris-compose/command.py | 147 +-
docker/runtime/doris-compose/database.py | 72 +-
docker/runtime/doris-compose/resource/init_be.sh | 6 +
.../runtime/doris-compose/resource/init_cloud.sh | 7 +
docker/runtime/doris-compose/resource/init_fe.sh | 15 +
.../fe/resource/fe_disaggregated_entrypoint.sh | 2 +
.../docker-compose/hive/hadoop-hive-2x.env.tpl | 17 +
.../docker-compose/hive/hadoop-hive-3x.env.tpl | 22 +
.../docker-compose/hive/hadoop-hive.env.tpl | 3 -
.../docker-compose/hive/hive-2x.yaml.tpl | 8 +-
.../docker-compose/hive/hive-3x.yaml.tpl | 8 +-
.../docker-compose/hive/scripts/hive-metastore.sh | 21 +-
.../scripts/create_preinstalled_scripts/run06.sql | 25 +
docker/thirdparties/run-thirdparties-docker.sh | 14 +-
.../org/apache/doris/jdbc/BaseJdbcExecutor.java | 5 +-
.../org/apache/doris/jdbc/GbaseJdbcExecutor.java | 89 +
.../org/apache/doris/jdbc/JdbcExecutorFactory.java | 2 +
.../doris/maxcompute/MaxComputeColumnValue.java | 86 +-
.../doris/maxcompute/MaxComputeJniScanner.java | 1 +
.../main/java/org/apache/doris/common/Config.java | 56 +-
.../antlr4/org/apache/doris/nereids/DorisLexer.g4 | 4 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 34 +-
fe/fe-core/src/main/cup/sql_parser.cup | 58 +-
.../main/java/org/apache/doris/alter/Alter.java | 23 +-
.../org/apache/doris/alter/CloudRollupJobV2.java | 10 +-
.../apache/doris/alter/CloudSchemaChangeJobV2.java | 14 +-
.../org/apache/doris/alter/IndexChangeJob.java | 7 +-
.../doris/alter/MaterializedViewHandler.java | 5 +-
.../java/org/apache/doris/alter/RollupJobV2.java | 10 +-
.../apache/doris/alter/SchemaChangeHandler.java | 22 +-
.../org/apache/doris/alter/SchemaChangeJobV2.java | 37 +-
.../java/org/apache/doris/alter/SystemHandler.java | 10 +-
.../org/apache/doris/analysis/BaseViewStmt.java | 11 +
.../java/org/apache/doris/analysis/ColumnDef.java | 10 +-
.../org/apache/doris/analysis/CreateTableStmt.java | 5 +-
.../org/apache/doris/analysis/CreateViewStmt.java | 13 +-
.../org/apache/doris/analysis/DescribeStmt.java | 28 +-
.../apache/doris/analysis/FunctionCallExpr.java | 1 +
.../java/org/apache/doris/analysis/KeysDesc.java | 65 +-
.../doris/analysis/LambdaFunctionCallExpr.java | 4 +-
.../apache/doris/analysis/NativeInsertStmt.java | 8 +
.../apache/doris/analysis/SetUserPropertyVar.java | 7 +
.../doris/analysis/ShowCacheHotSpotStmt.java | 7 +-
.../apache/doris/analysis/ShowCloudWarmUpStmt.java | 6 +-
.../org/apache/doris/analysis/ShowClusterStmt.java | 18 +-
.../org/apache/doris/analysis/ShowRolesStmt.java | 1 +
.../doris/analysis/ShowStorageVaultStmt.java | 2 +-
.../java/org/apache/doris/analysis/SlotRef.java | 1 -
.../java/org/apache/doris/backup/BackupJob.java | 8 +-
.../java/org/apache/doris/backup/RestoreJob.java | 185 +-
.../java/org/apache/doris/binlog/BinlogGcer.java | 2 +-
.../org/apache/doris/binlog/BinlogManager.java | 12 +
.../doris/catalog/BuiltinScalarFunctions.java | 20 +-
.../doris/catalog/BuiltinTableValuedFunctions.java | 4 +-
.../main/java/org/apache/doris/catalog/Column.java | 6 +
.../main/java/org/apache/doris/catalog/Env.java | 144 +-
.../doris/catalog/InternalSchemaInitializer.java | 19 +-
.../org/apache/doris/catalog/JdbcResource.java | 4 +
.../java/org/apache/doris/catalog/JdbcTable.java | 3 +
.../main/java/org/apache/doris/catalog/MTMV.java | 13 +-
.../org/apache/doris/catalog/MetadataViewer.java | 13 +-
.../java/org/apache/doris/catalog/OlapTable.java | 51 +-
.../java/org/apache/doris/catalog/Replica.java | 12 +-
.../org/apache/doris/catalog/StorageVault.java | 4 +-
.../java/org/apache/doris/catalog/TableIf.java | 2 -
.../org/apache/doris/catalog/TableProperty.java | 22 +
.../main/java/org/apache/doris/catalog/Tablet.java | 25 +-
.../apache/doris/catalog/TabletInvertedIndex.java | 6 +-
.../org/apache/doris/catalog/TabletStatMgr.java | 2 +-
.../main/java/org/apache/doris/catalog/View.java | 4 +-
.../hive/RangerHiveAccessControllerFactory.java | 6 +
.../org/apache/doris/clone/BeLoadRebalancer.java | 7 +-
.../org/apache/doris/clone/DiskRebalancer.java | 6 +-
.../apache/doris/clone/PartitionRebalancer.java | 9 +-
.../org/apache/doris/clone/TabletSchedCtx.java | 60 +-
.../org/apache/doris/clone/TabletScheduler.java | 42 +-
.../apache/doris/cloud/CacheHotspotManager.java | 63 +-
.../doris/cloud/CacheHotspotManagerUtils.java | 8 +-
.../doris/cloud/catalog/CloudClusterChecker.java | 47 +-
.../org/apache/doris/cloud/catalog/CloudEnv.java | 142 +-
.../apache/doris/cloud/catalog/CloudReplica.java | 109 +-
.../doris/cloud/catalog/CloudTabletRebalancer.java | 20 +-
.../cloud/datasource/CloudInternalCatalog.java | 18 +-
.../doris/cloud/load/CloudBrokerLoadJob.java | 17 +-
.../doris/cloud/qe/ComputeGroupException.java | 101 +
.../apache/doris/cloud/rpc/MetaServiceClient.java | 5 +
.../apache/doris/cloud/rpc/MetaServiceProxy.java | 10 +
.../doris/cloud/system/CloudSystemInfoService.java | 355 ++-
.../transaction/CloudGlobalTransactionMgr.java | 67 +-
.../java/org/apache/doris/common/ErrorCode.java | 4 +-
.../org/apache/doris/common/InternalErrorCode.java | 1 -
.../doris/common/RandomIdentifierGenerator.java | 51 +
.../org/apache/doris/common/UserException.java | 11 +-
.../org/apache/doris/common/proc/AuthProcDir.java | 2 +-
.../apache/doris/common/proc/ReplicasProcNode.java | 4 +-
.../apache/doris/common/proc/TabletsProcDir.java | 6 +-
.../doris/common/profile/ExecutionProfile.java | 54 +-
.../org/apache/doris/common/profile/Profile.java | 112 +-
.../doris/common/publish/TopicPublisherThread.java | 17 +-
.../org/apache/doris/common/util/DebugUtil.java | 59 +
.../common/util/FetchRemoteTabletSchemaUtil.java | 2 +-
.../apache/doris/common/util/FileFormatUtils.java | 15 +
.../doris/common/util/InternalDatabaseUtil.java | 3 +-
.../apache/doris/common/util/MetaLockUtils.java | 10 +-
.../apache/doris/common/util/ProfileManager.java | 3 +-
.../apache/doris/common/util/PropertyAnalyzer.java | 16 +-
.../org/apache/doris/common/util/TimeUtils.java | 35 +
.../doris/consistency/CheckConsistencyJob.java | 4 +-
.../org/apache/doris/datasource/CatalogIf.java | 23 +
.../apache/doris/datasource/ExternalCatalog.java | 38 +-
.../doris/datasource/ExternalMetaCacheMgr.java | 2 +-
.../apache/doris/datasource/FileQueryScanNode.java | 1 +
.../org/apache/doris/datasource/FileScanNode.java | 5 +-
.../apache/doris/datasource/InternalCatalog.java | 98 +-
.../doris/datasource/hive/HMSExternalCatalog.java | 94 +-
.../doris/datasource/hive/HMSExternalTable.java | 23 +-
.../doris/datasource/hive/HiveMetaStoreCache.java | 74 +-
.../doris/datasource/hive/HiveMetadataOps.java | 14 +-
.../doris/datasource/hive/source/HiveScanNode.java | 44 +-
.../datasource/iceberg/IcebergMetadataOps.java | 12 +-
.../doris/datasource/jdbc/client/JdbcClient.java | 3 +
.../datasource/jdbc/client/JdbcGbaseClient.java | 158 ++
.../maxcompute/MaxComputeExternalCatalog.java | 47 +-
.../maxcompute/source/MaxComputeScanNode.java | 37 +-
.../datasource/paimon/source/PaimonScanNode.java | 29 +-
.../datasource/paimon/source/PaimonSource.java | 4 +-
.../org/apache/doris/deploy/DeployManager.java | 4 +-
.../org/apache/doris/event/DropPartitionEvent.java | 9 +-
.../httpv2/controller/HardwareInfoController.java | 351 +--
.../org/apache/doris/httpv2/rest/LoadAction.java | 8 +-
.../apache/doris/httpv2/rest/MetaInfoAction.java | 1 +
.../org/apache/doris/httpv2/rest/ShowAction.java | 24 +-
.../doris/httpv2/rest/TableQueryPlanAction.java | 252 +-
.../doris/httpv2/rest/manager/ClusterAction.java | 7 +-
.../doris/httpv2/rest/manager/NodeAction.java | 2 +-
.../httpv2/rest/manager/QueryProfileAction.java | 4 +-
.../doris/httpv2/restv2/MetaInfoActionV2.java | 25 +-
.../insertoverwrite/InsertOverwriteManager.java | 58 +
.../doris/insertoverwrite/InsertOverwriteUtil.java | 2 +-
.../doris/job/extensions/insert/InsertTask.java | 4 +-
.../apache/doris/job/extensions/mtmv/MTMVJob.java | 2 +-
.../apache/doris/job/extensions/mtmv/MTMVTask.java | 8 +-
.../main/java/org/apache/doris/load/DeleteJob.java | 2 +-
.../org/apache/doris/load/ExportTaskExecutor.java | 18 +-
.../org/apache/doris/load/GroupCommitManager.java | 22 +-
.../src/main/java/org/apache/doris/load/Load.java | 91 -
.../apache/doris/load/loadv2/BrokerLoadJob.java | 88 +-
.../java/org/apache/doris/load/loadv2/LoadJob.java | 6 +-
.../apache/doris/load/loadv2/MysqlLoadManager.java | 19 +-
.../org/apache/doris/load/loadv2/SparkLoadJob.java | 61 +-
.../load/routineload/KafkaRoutineLoadJob.java | 3 +-
.../doris/load/routineload/KafkaTaskInfo.java | 13 +-
.../doris/load/routineload/RoutineLoadJob.java | 21 +-
.../load/routineload/RoutineLoadTaskInfo.java | 45 +-
.../java/org/apache/doris/master/MasterImpl.java | 14 +-
.../org/apache/doris/master/ReportHandler.java | 19 +-
.../org/apache/doris/metric/JsonMetricVisitor.java | 5 +
.../java/org/apache/doris/metric/MetricRepo.java | 2 +
.../org/apache/doris/metric/MetricVisitor.java | 2 +
.../doris/metric/PrometheusMetricVisitor.java | 27 +
.../doris/metric/SimpleCoreMetricVisitor.java | 6 +
.../java/org/apache/doris/mtmv/MTMVService.java | 4 +
.../java/org/apache/doris/mysql/MysqlProto.java | 6 +-
.../mysql/privilege/AccessControllerFactory.java | 8 +
.../mysql/privilege/AccessControllerManager.java | 99 +-
.../org/apache/doris/mysql/privilege/Auth.java | 7 +
.../RangerDorisAccessControllerFactory.java | 34 +
.../apache/doris/mysql/privilege/RoleManager.java | 4 +-
.../apache/doris/mysql/privilege/UserProperty.java | 18 +
.../org/apache/doris/nereids/NereidsPlanner.java | 16 +-
.../glue/translator/ExpressionTranslator.java | 7 +-
.../glue/translator/PhysicalPlanTranslator.java | 95 +-
.../doris/nereids/jobs/executor/Analyzer.java | 2 +
.../doris/nereids/jobs/executor/Rewriter.java | 7 +-
.../nereids/jobs/scheduler/SimpleJobScheduler.java | 4 +-
.../apache/doris/nereids/memo/GroupExpression.java | 22 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 15 +-
.../nereids/processor/post/PlanPostProcessors.java | 3 +
.../post/ProjectAggregateExpressionsForCse.java | 150 ++
.../post/PushDownFilterThroughProject.java | 3 +-
.../processor/post/RuntimeFilterContext.java | 20 +-
.../processor/post/RuntimeFilterGenerator.java | 273 +--
.../doris/nereids/processor/post/TopNScanOpt.java | 14 -
.../processor/post/TopnFilterPushDownVisitor.java | 11 +-
.../doris/nereids/processor/post/Validator.java | 8 +-
.../org/apache/doris/nereids/rules/RuleType.java | 1 +
.../doris/nereids/rules/analysis/BindRelation.java | 24 +-
.../rules/analysis/EliminateLogicalSelectHint.java | 7 -
.../nereids/rules/analysis/ExpressionAnalyzer.java | 15 -
.../nereids/rules/analysis/FillUpMissingSlots.java | 73 +-
.../nereids/rules/analysis/NormalizeGenerate.java | 64 +
.../nereids/rules/analysis/SubExprAnalyzer.java | 259 ++-
.../nereids/rules/analysis/SubqueryToApply.java | 160 +-
.../nereids/rules/analysis/UserAuthentication.java | 6 +-
.../mv/AbstractMaterializedViewAggregateRule.java | 50 +
.../mv/AbstractMaterializedViewRule.java | 25 +
.../exploration/mv/MaterializedViewUtils.java | 27 +-
.../expression/rules/FoldConstantRuleOnBE.java | 11 +-
.../expression/rules/FoldConstantRuleOnFE.java | 33 +-
.../rules/expression/rules/SimplifyCastRule.java | 11 +-
.../rules/SimplifyComparisonPredicate.java | 24 +-
.../rules/SimplifyDecimalV3Comparison.java | 25 +-
.../rules/implementation/AggregateStrategies.java | 6 +-
.../nereids/rules/rewrite/AdjustNullable.java | 12 +
.../ExtractAndNormalizeWindowExpression.java | 20 +-
...CorrelatedFilterUnderApplyAggregateProject.java | 23 +-
.../rules/rewrite/PullUpProjectUnderApply.java | 10 +-
.../rewrite/PushDownFilterThroughProject.java | 4 +-
.../doris/nereids/stats/ExpressionEstimation.java | 46 +-
.../doris/nereids/stats/FilterEstimation.java | 41 +-
.../doris/nereids/stats/StatsCalculator.java | 65 +-
.../org/apache/doris/nereids/trees/TreeNode.java | 17 +
.../nereids/trees/expressions/ExecFunction.java | 14 -
.../trees/expressions/ExpressionEvaluator.java | 205 +-
.../nereids/trees/expressions/ScalarSubquery.java | 62 +-
.../expressions/functions/AlwaysNotNullable.java | 9 +
.../functions/ComputePrecisionForRound.java | 4 +-
.../expressions/functions/NoneMovableFunction.java | 25 +
.../trees/expressions/functions/agg/ArrayAgg.java | 7 +
.../trees/expressions/functions/agg/BitmapAgg.java | 6 +
.../expressions/functions/agg/BitmapIntersect.java | 6 +
.../expressions/functions/agg/BitmapUnion.java | 6 +
.../functions/agg/BitmapUnionCount.java | 7 +
.../expressions/functions/agg/BitmapUnionInt.java | 6 +
.../expressions/functions/agg/CollectList.java | 7 +
.../expressions/functions/agg/CollectSet.java | 7 +
.../trees/expressions/functions/agg/Count.java | 6 +
.../expressions/functions/agg/CountByEnum.java | 6 +
.../functions/agg/GroupArrayIntersect.java | 7 +
.../trees/expressions/functions/agg/Histogram.java | 6 +
.../trees/expressions/functions/agg/HllUnion.java | 6 +
.../expressions/functions/agg/HllUnionAgg.java | 6 +
.../expressions/functions/agg/IntersectCount.java | 6 +
.../trees/expressions/functions/agg/MapAgg.java | 7 +
.../functions/agg/MultiDistinctCount.java | 6 +
.../functions/agg/MultiDistinctSum0.java | 23 +
.../trees/expressions/functions/agg/Ndv.java | 6 +
.../expressions/functions/agg/PercentileArray.java | 7 +
.../expressions/functions/agg/QuantileUnion.java | 6 +
.../expressions/functions/agg/SequenceCount.java | 6 +
.../trees/expressions/functions/agg/Sum0.java | 22 +
.../functions/executable/DateTimeAcquire.java | 24 +-
.../functions/executable/DateTimeArithmetic.java | 122 +-
.../executable/DateTimeExtractAndTransform.java | 276 +--
.../functions/executable/ExecutableFunctions.java | 35 +-
.../functions/executable/NumericArithmetic.java | 174 +-
.../functions/executable/StringArithmetic.java | 126 +-
.../functions/executable/TimeRoundSeries.java | 288 +--
.../expressions/functions/scalar/ArrayApply.java | 2 +-
.../functions/scalar/ArrayMatchAll.java | 68 +
.../functions/scalar/ArrayMatchAny.java | 68 +
.../expressions/functions/scalar/AssertTrue.java | 3 +-
.../functions/scalar/FromIso8601Date.java | 72 +
.../expressions/functions/scalar/JsonSearch.java | 62 +
.../expressions/functions/scalar/LastQueryId.java | 59 +
.../expressions/functions/scalar/NormalCdf.java | 69 +
.../expressions/functions/scalar/ToIso8601.java | 76 +
.../expressions/functions/scalar/Translate.java | 72 +
.../expressions/functions/scalar/UrlEncode.java | 70 +
.../trees/expressions/functions/table/Numbers.java | 2 +-
.../functions/table/PartitionValues.java | 76 +
.../expressions/literal/DecimalV3Literal.java | 8 +-
.../expressions/visitor/ScalarFunctionVisitor.java | 45 +
.../visitor/TableValuedFunctionVisitor.java | 5 +
.../nereids/trees/plans/ComputeResultSet.java | 5 +-
.../org/apache/doris/nereids/trees/plans/Plan.java | 4 +-
.../doris/nereids/trees/plans/algebra/Project.java | 22 +-
.../trees/plans/commands/AlterMTMVCommand.java | 2 +-
.../plans/commands/CancelMTMVTaskCommand.java | 2 +-
.../trees/plans/commands/CreateMTMVCommand.java | 2 +-
.../trees/plans/commands/DropMTMVCommand.java | 2 +-
.../trees/plans/commands/NotAllowFallback.java | 25 -
.../trees/plans/commands/PauseMTMVCommand.java | 2 +-
.../trees/plans/commands/RefreshMTMVCommand.java | 2 +-
.../trees/plans/commands/ResumeMTMVCommand.java | 2 +-
.../plans/commands/ShowCreateMTMVCommand.java | 2 +-
.../plans/commands/info/ColumnDefinition.java | 8 +-
.../trees/plans/commands/info/CreateMTMVInfo.java | 21 +-
.../trees/plans/commands/info/CreateTableInfo.java | 91 +-
.../trees/plans/commands/info/CreateViewInfo.java | 8 +-
.../trees/plans/commands/info/DefaultValue.java | 3 +-
.../commands/insert/AbstractInsertExecutor.java | 34 +-
.../insert/BaseExternalTableInsertExecutor.java | 13 -
.../plans/commands/insert/HiveInsertExecutor.java | 8 +-
.../commands/insert/IcebergInsertExecutor.java | 8 +-
.../commands/insert/InsertIntoTableCommand.java | 1 +
.../insert/InsertOverwriteTableCommand.java | 71 +-
.../trees/plans/commands/insert/InsertUtils.java | 6 +
.../plans/commands/insert/JdbcInsertExecutor.java | 5 -
.../plans/commands/insert/OlapInsertExecutor.java | 8 +-
.../worker/job/UnassignedJobBuilder.java | 8 -
.../job/UnassignedScanBucketOlapTableJob.java | 2 +-
.../trees/plans/logical/LogicalOlapScan.java | 3 -
.../trees/plans/logical/LogicalProject.java | 12 +-
.../plans/physical/PhysicalEmptyRelation.java | 6 +-
.../trees/plans/physical/PhysicalFileSink.java | 9 +-
.../plans/physical/PhysicalOneRowRelation.java | 28 +-
.../trees/plans/physical/PhysicalResultSink.java | 5 +-
.../trees/plans/physical/PhysicalSqlCache.java | 2 +-
.../org/apache/doris/nereids/types/DataType.java | 2 +-
.../org/apache/doris/nereids/types/StringType.java | 5 -
.../nereids/types/coercion/CharacterType.java | 2 +-
.../apache/doris/nereids/util/RelationUtil.java | 6 +-
.../java/org/apache/doris/persist/EditLog.java | 4 +-
.../doris/persist/TableRenameColumnInfo.java | 4 +
.../org/apache/doris/planner/DataStreamSink.java | 10 +
.../org/apache/doris/planner/OlapScanNode.java | 26 +-
.../org/apache/doris/planner/OlapTableSink.java | 26 +-
.../org/apache/doris/planner/OriginalPlanner.java | 1 -
.../org/apache/doris/planner/PlanFragment.java | 6 +-
.../apache/doris/planner/StreamLoadPlanner.java | 12 +-
.../doris/plsql/executor/PlsqlQueryExecutor.java | 3 +-
.../org/apache/doris/plugin/PropertiesUtils.java | 53 +
.../java/org/apache/doris/qe/AuditLogHelper.java | 27 +-
.../apache/doris/qe/AutoCloseConnectContext.java | 1 +
.../java/org/apache/doris/qe/ConnectContext.java | 80 +-
.../java/org/apache/doris/qe/ConnectProcessor.java | 117 +-
.../java/org/apache/doris/qe/ConnectScheduler.java | 5 +-
.../main/java/org/apache/doris/qe/Coordinator.java | 62 +-
.../main/java/org/apache/doris/qe/DdlExecutor.java | 6 +-
.../java/org/apache/doris/qe/FEOpExecutor.java | 8 +-
.../java/org/apache/doris/qe/MasterOpExecutor.java | 12 +-
.../org/apache/doris/qe/MysqlConnectProcessor.java | 10 +-
.../org/apache/doris/qe/PointQueryExecutor.java | 5 +-
.../java/org/apache/doris/qe/QeProcessorImpl.java | 19 -
.../java/org/apache/doris/qe/SessionVariable.java | 83 +-
.../java/org/apache/doris/qe/ShowExecutor.java | 19 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 262 +--
.../main/java/org/apache/doris/qe/VariableMgr.java | 36 +
.../main/java/org/apache/doris/resource/Tag.java | 4 +
.../resource/workloadgroup/WorkloadGroupMgr.java | 25 +
.../WorkloadActionCancelQuery.java | 4 +-
.../apache/doris/service/FrontendServiceImpl.java | 29 +-
.../arrowflight/FlightSqlConnectProcessor.java | 2 +-
.../sessions/FlightSqlConnectContext.java | 4 +-
.../doris/statistics/AnalysisInfoBuilder.java | 2 +-
.../apache/doris/statistics/AnalysisManager.java | 93 +-
.../apache/doris/statistics/BaseAnalysisTask.java | 4 +-
.../org/apache/doris/statistics/ColStatsData.java | 3 +-
.../apache/doris/statistics/ColumnStatistic.java | 33 +-
.../doris/statistics/ColumnStatisticBuilder.java | 22 +-
.../doris/statistics/OlapScanStatsDerive.java | 3 -
.../doris/statistics/PartitionColumnStatistic.java | 11 +-
.../PartitionColumnStatisticBuilder.java | 4 +-
.../org/apache/doris/statistics/Statistics.java | 11 +-
.../doris/statistics/StatisticsRepository.java | 3 +-
.../apache/doris/statistics/StatsDeriveResult.java | 21 -
.../apache/doris/statistics/TableStatsMeta.java | 11 +-
.../doris/statistics/util/StatisticsUtil.java | 91 +-
.../main/java/org/apache/doris/system/Backend.java | 24 +-
.../java/org/apache/doris/system/Diagnoser.java | 29 +-
.../java/org/apache/doris/system/Frontend.java | 11 +
.../java/org/apache/doris/system/HeartbeatMgr.java | 8 +
.../org/apache/doris/system/SystemInfoService.java | 9 +
.../doris/tablefunction/MetadataGenerator.java | 342 ++-
.../PartitionValuesTableValuedFunction.java | 180 ++
.../PartitionsTableValuedFunction.java | 2 +-
.../doris/tablefunction/TableValuedFunctionIf.java | 2 +
.../AbstractExternalTransactionManager.java | 81 +
.../doris/transaction/DatabaseTransactionMgr.java | 60 +-
.../GlobalExternalTransactionInfoMgr.java | 43 +
.../doris/transaction/GlobalTransactionMgr.java | 5 +-
.../transaction/GlobalTransactionMgrIface.java | 1 +
.../doris/transaction/HiveTransactionManager.java | 47 +-
.../transaction/IcebergTransactionManager.java | 47 +-
.../doris/transaction/TransactionManager.java | 2 +-
fe/fe-core/src/main/jflex/sql_scanner.flex | 2 +
...e.doris.mysql.privilege.AccessControllerFactory | 19 +
.../apache/doris/analysis/InsertArrayStmtTest.java | 25 +-
.../doris/analysis/RangePartitionPruneTest.java | 96 +-
.../org/apache/doris/analysis/SelectStmtTest.java | 1087 ---------
.../org/apache/doris/analysis/SetVariableTest.java | 2 +-
.../apache/doris/analysis/StmtRewriterTest.java | 627 -----
.../analysis/TableNameComparedLowercaseTest.java | 17 -
.../org/apache/doris/catalog/CatalogTestUtil.java | 4 +-
.../apache/doris/catalog/CreateFunctionTest.java | 154 +-
.../apache/doris/catalog/ModifyBackendTest.java | 4 +-
.../java/org/apache/doris/catalog/ReplicaTest.java | 2 +-
.../java/org/apache/doris/catalog/TabletTest.java | 10 +-
.../org/apache/doris/clone/DecommissionTest.java | 2 +-
.../doris/clone/DiskReblanceWhenSchedulerIdle.java | 2 +-
.../transaction/CloudGlobalTransactionMgrTest.java | 8 +-
.../doris/cluster/DecommissionBackendTest.java | 8 +-
.../apache/doris/common/util/TimeUtilsTest.java | 51 +
.../datasource/RoundRobinCreateTabletTest.java | 2 +-
.../datasource/hive/HiveDDLAndDMLPlanTest.java | 2 +-
.../datasource/hive/HiveMetaStoreCacheTest.java | 92 +
.../apache/doris/external/hms/HmsCatalogTest.java | 1 -
.../doris/http/TableQueryPlanActionTest.java | 18 +
.../InsertOverwriteManagerTest.java | 77 +
.../load/routineload/KafkaRoutineLoadJobTest.java | 2 +-
.../doris/load/routineload/RoutineLoadJobTest.java | 1 -
.../routineload/RoutineLoadTaskSchedulerTest.java | 2 +-
.../org/apache/doris/mysql/privilege/AuthTest.java | 2 +-
.../doris/nereids/memo/GroupExpressionTest.java | 62 +
.../apache/doris/nereids/metrics/EventTest.java | 1 -
.../nereids/mv/MtmvCacheNewConnectContextTest.java | 84 +
.../doris/nereids/preprocess/SelectHintTest.java | 79 -
.../privileges/CustomAccessControllerFactory.java | 35 +
.../nereids/privileges/TestCheckPrivileges.java | 23 +-
.../nereids/rules/analysis/BindRelationTest.java | 9 +
.../nereids/rules/analysis/CheckRowPolicyTest.java | 2 -
.../exploration/mv/MaterializedViewUtilsTest.java | 20 +
.../nereids/rules/expression/FoldConstantTest.java | 16 +
.../expression/rules/SimplifyCastRuleTest.java | 46 +-
.../rules/SimplifyComparisonPredicateTest.java | 130 ++
.../rules/SimplifyDecimalV3ComparisonTest.java | 50 +-
.../nereids/rules/rewrite/AdjustNullableTest.java | 74 +
.../nereids/stats/ExpressionEstimationTest.java | 63 +
.../doris/nereids/stats/FilterEstimationTest.java | 192 +-
.../doris/nereids/stats/JoinEstimateTest.java | 15 +-
.../doris/nereids/stats/StatsCalculatorTest.java | 8 +-
.../org/apache/doris/planner/ColocatePlanTest.java | 309 ---
.../doris/planner/DistributedPlannerTest.java | 171 --
.../java/org/apache/doris/planner/PlannerTest.java | 734 ------
.../doris/planner/ProjectPlannerFunctionTest.java | 111 -
.../doris/planner/QueryCacheNormalizerTest.java | 3 -
.../org/apache/doris/planner/QueryPlanTest.java | 2300 -------------------
.../org/apache/doris/planner/RepeatNodeTest.java | 80 -
.../apache/doris/planner/ResourceTagQueryTest.java | 2 +-
.../doris/planner/TableFunctionPlanTest.java | 554 -----
.../java/org/apache/doris/policy/PolicyTest.java | 96 -
.../org/apache/doris/qe/SessionVariablesTest.java | 37 +-
.../java/org/apache/doris/qe/StmtExecutorTest.java | 6 +-
.../ExtractCommonFactorsRuleFunctionTest.java | 338 ---
.../apache/doris/rewrite/InferFiltersRuleTest.java | 404 ----
.../rewrite/RewriteBinaryPredicatesRuleTest.java | 129 --
.../doris/rewrite/RewriteInPredicateRuleTest.java | 144 --
.../doris/statistics/StatsDeriveResultTest.java | 58 -
.../transaction/DatabaseTransactionMgrTest.java | 2 +-
.../transaction/GlobalTransactionMgrTest.java | 20 +-
.../org/apache/doris/utframe/AnotherDemoTest.java | 2 +-
.../java/org/apache/doris/utframe/DemoTest.java | 2 +-
...e.doris.mysql.privilege.AccessControllerFactory | 18 +
gensrc/proto/cloud.proto | 14 +
gensrc/proto/descriptors.proto | 1 +
gensrc/proto/internal_service.proto | 2 +
gensrc/proto/olap_file.proto | 1 +
gensrc/script/doris_builtins_functions.py | 2 +
gensrc/script/gen_builtins_functions.py | 11 +-
gensrc/thrift/Data.thrift | 1 +
gensrc/thrift/DataSinks.thrift | 1 +
gensrc/thrift/FrontendService.thrift | 2 +
gensrc/thrift/HeartbeatService.thrift | 2 +
gensrc/thrift/PaloInternalService.thrift | 24 +-
gensrc/thrift/PlanNodes.thrift | 8 +
gensrc/thrift/Types.thrift | 6 +-
regression-test/conf/regression-conf.groovy | 10 +
.../test_backup_restore_atomic_with_view.out | 60 +
.../test_insert_overwrite_recover.out | 14 +
...compaction_remove_old_version_delete_bitmap.out | 29 +
.../correctness/test_column_nullable_cache.out | 6 +
.../correctness/test_scan_keys_with_bool_type.out | 43 +
...ays_nullable_window_function_legacy_planner.out | 97 -
.../data/correctness_p0/test_colocate_join.out | 22 -
.../correctness_p0/test_default_bitmap_empty.out | 43 +
...sv => test_default_bitmap_empty_streamload.csv} | 0
.../test_first_value_window_legacy_planner.out | 43 -
.../test_last_value_window_legacy_planner.out | 30 -
.../data/correctness_p0/test_set_operation.out | 3 -
.../duplicate/storage/test_duplicate_bitmap.out | 24 -
.../duplicate/storage/test_duplicate_hll.out | 56 -
.../storage/test_duplicate_quantile_state.out | 42 -
.../data_model_p0/unique/test_unique_bitmap.out | 20 -
.../data/data_model_p0/unique/test_unique_hll.out | 92 -
.../unique/test_unique_quantile_state.out | 60 -
.../unique/test_unique_table_auto_inc.out | 14 -
.../data/datatype_p0/decimalv3/test_decimalv3.out | 12 -
.../test_array_zip_array_enumerate_uniq.out | 12 -
.../get_assignment_compatible_type.out | 2 +-
.../data/ddl_p0/test_create_or_replace_view.out | 7 +
.../test_create_table_generated_column_legacy.out | 93 -
.../test_delete_generated_column.out | 24 -
regression-test/data/ddl_p0/test_create_view.out | 29 -
.../data/delete_p0/test_delete_on_mor.out | 25 -
.../data/export_p0/test_export_data_types.out | 48 +-
.../data/export_p2/test_export_max_file_size.out | 2003 ++++++++--------
.../hive/test_hive_partition_values_tvf.out | 120 +
.../jdbc/test_doris_jdbc_catalog.out | 8 +
.../jdbc/test_gbase_jdbc_catalog.out | 31 +
.../jdbc/test_jdbc_catalog_ddl.out | 27 +
.../external_table_p0/jdbc/test_jdbc_query_pg.out | 6 +-
.../paimon/paimon_tb_mix_format.out | 45 +
.../data/external_table_p0/tvf/test_hdfs_tvf.out | 44 +
.../data/external_table_p0/tvf/upgrade/test.out | 45 +
.../test_external_catalog_maxcompute.out | 18 +
.../test_cloud_mow_broker_load_with_retry.out | 7 +
.../cloud/test_cloud_mow_insert_with_retry.out | 8 +
.../group_commit/replay_wal_restart_fe.out | 4 +
.../data/insert_p0/insert_group_commit_into.out | 108 -
.../insert_group_commit_into_max_filter_ratio.out | 6 -
.../insert_p0/insert_group_commit_into_unique.out | 88 -
.../insert_group_commit_into_unique_sync_mode.out | 88 -
.../data/insert_p0/insert_with_null.out | 20 -
.../data/inverted_index_p0/count-on-index.json | 100 +
.../data/inverted_index_p0/test_count_on_index.out | 3 +
.../http_stream/test_http_stream_properties.out | 1452 ++++++------
.../stream_load/test_stream_load_properties.out | 2100 ++++++++---------
.../data/manager/test_manager_interface_1.out | 22 +-
.../mv_p0/test_duplicate_mv/test_duplicate_mv.out | 10 +
.../agg_function/test_covar_samp.out | 8 +-
.../data/nereids_function_p0/fn_test_am.csv | 102 +
.../nereids_function_p0/scalar_function/Array.out | 1320 +++++++++++
.../data/nereids_function_p0/scalar_function/R.out | 6 +
.../data/nereids_hint_tpcds_p0/shape/query1.out | 10 +-
.../data/nereids_hint_tpcds_p0/shape/query11.out | 12 +-
.../data/nereids_hint_tpcds_p0/shape/query14.out | 79 +-
.../data/nereids_hint_tpcds_p0/shape/query23.out | 18 +-
.../data/nereids_hint_tpcds_p0/shape/query30.out | 4 +-
.../data/nereids_hint_tpcds_p0/shape/query31.out | 20 +-
.../data/nereids_hint_tpcds_p0/shape/query39.out | 4 +-
.../data/nereids_hint_tpcds_p0/shape/query4.out | 20 +-
.../data/nereids_hint_tpcds_p0/shape/query41.out | 2 +-
.../data/nereids_hint_tpcds_p0/shape/query47.out | 8 +-
.../data/nereids_hint_tpcds_p0/shape/query57.out | 8 +-
.../data/nereids_hint_tpcds_p0/shape/query64.out | 107 +-
.../data/nereids_hint_tpcds_p0/shape/query66.out | 103 +-
.../data/nereids_hint_tpcds_p0/shape/query74.out | 16 +-
.../data/nereids_hint_tpcds_p0/shape/query75.out | 4 +-
.../data/nereids_hint_tpcds_p0/shape/query81.out | 4 +-
.../data/nereids_p0/hint/multi_leading.out | 94 +-
regression-test/data/nereids_p0/hint/test_hint.out | 12 +-
.../data/nereids_p0/insert_into_table/random.out | 3 +
.../test_aggregate_window_functions.out | 822 +++++++
.../datetime_functions/test_date_function.out | 15 +
.../sql_functions/math_functions/test_conv.out | 3 +
.../string_functions/test_string_function.out | 60 +
.../subquery/correlated_scalar_subquery.out | 108 +
.../cte/test_cte_filter_pushdown.out | 8 +-
.../nereids_rules_p0/eager_aggregate/basic.out | 4 +-
.../eager_aggregate/basic_one_side.out | 4 +-
.../eliminate_outer_join/eliminate_outer_join.out | 40 +-
.../infer_predicate/infer_intersect_except.out | 4 +-
.../union_all_compensate/union_all_compensate.out | 201 ++
.../normalize_window_nullable_agg_test.out | 293 +++
.../extract_from_disjunction_in_join.out | 14 +-
.../nereids_syntax_p0/mv/aggregate/agg_sync_mv.out | 60 +
.../data/nereids_syntax_p0/window_function.out | 202 ++
.../mv/agg_mv_test.dat | 0
.../nereids_syntax_p1/mv/aggregate/agg_sync_mv.out | 1516 ++++++++++++
.../nereids_tpcds_shape_sf1000_p0/shape/query1.out | 10 +-
.../shape/query11.out | 12 +-
.../shape/query14.out | 79 +-
.../shape/query23.out | 18 +-
.../shape/query30.out | 4 +-
.../shape/query31.out | 20 +-
.../shape/query39.out | 4 +-
.../nereids_tpcds_shape_sf1000_p0/shape/query4.out | 20 +-
.../shape/query41.out | 2 +-
.../shape/query47.out | 8 +-
.../shape/query57.out | 8 +-
.../shape/query64.out | 139 +-
.../shape/query66.out | 103 +-
.../shape/query74.out | 16 +-
.../shape/query75.out | 4 +-
.../shape/query81.out | 4 +-
.../constraints/query23.out | 14 +-
.../noStatsRfPrune/query11.out | 12 +-
.../noStatsRfPrune/query14.out | 63 +-
.../noStatsRfPrune/query23.out | 12 +-
.../noStatsRfPrune/query31.out | 18 +-
.../noStatsRfPrune/query39.out | 4 +-
.../noStatsRfPrune/query4.out | 20 +-
.../noStatsRfPrune/query41.out | 2 +-
.../noStatsRfPrune/query47.out | 4 +-
.../noStatsRfPrune/query57.out | 8 +-
.../noStatsRfPrune/query64.out | 4 +-
.../noStatsRfPrune/query66.out | 103 +-
.../noStatsRfPrune/query74.out | 16 +-
.../noStatsRfPrune/query75.out | 4 +-
.../no_stats_shape/query1.out | 6 +-
.../no_stats_shape/query11.out | 12 +-
.../no_stats_shape/query14.out | 81 +-
.../no_stats_shape/query23.out | 18 +-
.../no_stats_shape/query30.out | 4 +-
.../no_stats_shape/query31.out | 18 +-
.../no_stats_shape/query39.out | 4 +-
.../no_stats_shape/query4.out | 20 +-
.../no_stats_shape/query41.out | 2 +-
.../no_stats_shape/query47.out | 8 +-
.../no_stats_shape/query57.out | 8 +-
.../no_stats_shape/query64.out | 4 +-
.../no_stats_shape/query66.out | 103 +-
.../no_stats_shape/query74.out | 16 +-
.../no_stats_shape/query75.out | 4 +-
.../no_stats_shape/query81.out | 4 +-
.../rf_prune/query1.out | 4 +-
.../rf_prune/query11.out | 12 +-
.../rf_prune/query14.out | 59 +-
.../rf_prune/query23.out | 18 +-
.../rf_prune/query31.out | 20 +-
.../rf_prune/query39.out | 4 +-
.../rf_prune/query4.out | 20 +-
.../rf_prune/query41.out | 2 +-
.../rf_prune/query47.out | 4 +-
.../rf_prune/query57.out | 4 +-
.../rf_prune/query64.out | 137 +-
.../rf_prune/query66.out | 103 +-
.../rf_prune/query74.out | 12 +-
.../rf_prune/query75.out | 4 +-
.../nereids_tpcds_shape_sf100_p0/shape/query1.out | 10 +-
.../nereids_tpcds_shape_sf100_p0/shape/query11.out | 12 +-
.../nereids_tpcds_shape_sf100_p0/shape/query14.out | 79 +-
.../nereids_tpcds_shape_sf100_p0/shape/query23.out | 18 +-
.../nereids_tpcds_shape_sf100_p0/shape/query30.out | 4 +-
.../nereids_tpcds_shape_sf100_p0/shape/query31.out | 20 +-
.../nereids_tpcds_shape_sf100_p0/shape/query39.out | 4 +-
.../nereids_tpcds_shape_sf100_p0/shape/query4.out | 20 +-
.../nereids_tpcds_shape_sf100_p0/shape/query41.out | 2 +-
.../nereids_tpcds_shape_sf100_p0/shape/query47.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query57.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query64.out | 4 +-
.../nereids_tpcds_shape_sf100_p0/shape/query66.out | 103 +-
.../nereids_tpcds_shape_sf100_p0/shape/query74.out | 12 +-
.../nereids_tpcds_shape_sf100_p0/shape/query75.out | 4 +-
.../nereids_tpcds_shape_sf100_p0/shape/query81.out | 4 +-
.../data/nereids_tpch_p0/tpch/agg_cse.out | 33 +
.../data/new_shapes_p0/hint_tpcds/shape/query1.out | 8 +-
.../new_shapes_p0/hint_tpcds/shape/query64.out | 4 +-
.../tpcds_sf100/constraints/query23.out | 14 +-
.../tpcds_sf100/noStatsRfPrune/query11.out | 12 +-
.../tpcds_sf100/noStatsRfPrune/query14.out | 63 +-
.../tpcds_sf100/noStatsRfPrune/query23.out | 12 +-
.../tpcds_sf100/noStatsRfPrune/query31.out | 18 +-
.../tpcds_sf100/noStatsRfPrune/query39.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query4.out | 20 +-
.../tpcds_sf100/noStatsRfPrune/query41.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query47.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query57.out | 8 +-
.../tpcds_sf100/noStatsRfPrune/query64.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query66.out | 103 +-
.../tpcds_sf100/noStatsRfPrune/query74.out | 16 +-
.../tpcds_sf100/noStatsRfPrune/query75.out | 4 +-
.../tpcds_sf100/no_stats_shape/query1.out | 6 +-
.../tpcds_sf100/no_stats_shape/query11.out | 12 +-
.../tpcds_sf100/no_stats_shape/query14.out | 81 +-
.../tpcds_sf100/no_stats_shape/query23.out | 18 +-
.../tpcds_sf100/no_stats_shape/query30.out | 4 +-
.../tpcds_sf100/no_stats_shape/query31.out | 18 +-
.../tpcds_sf100/no_stats_shape/query39.out | 4 +-
.../tpcds_sf100/no_stats_shape/query4.out | 20 +-
.../tpcds_sf100/no_stats_shape/query41.out | 2 +-
.../tpcds_sf100/no_stats_shape/query47.out | 8 +-
.../tpcds_sf100/no_stats_shape/query57.out | 8 +-
.../tpcds_sf100/no_stats_shape/query64.out | 4 +-
.../tpcds_sf100/no_stats_shape/query66.out | 103 +-
.../tpcds_sf100/no_stats_shape/query74.out | 16 +-
.../tpcds_sf100/no_stats_shape/query75.out | 4 +-
.../tpcds_sf100/no_stats_shape/query81.out | 4 +-
.../new_shapes_p0/tpcds_sf100/rf_prune/query1.out | 4 +-
.../new_shapes_p0/tpcds_sf100/rf_prune/query11.out | 12 +-
.../new_shapes_p0/tpcds_sf100/rf_prune/query14.out | 59 +-
.../new_shapes_p0/tpcds_sf100/rf_prune/query23.out | 18 +-
.../new_shapes_p0/tpcds_sf100/rf_prune/query31.out | 20 +-
.../new_shapes_p0/tpcds_sf100/rf_prune/query39.out | 4 +-
.../new_shapes_p0/tpcds_sf100/rf_prune/query4.out | 20 +-
.../new_shapes_p0/tpcds_sf100/rf_prune/query41.out | 2 +-
.../new_shapes_p0/tpcds_sf100/rf_prune/query47.out | 4 +-
.../new_shapes_p0/tpcds_sf100/rf_prune/query57.out | 4 +-
.../new_shapes_p0/tpcds_sf100/rf_prune/query64.out | 4 +-
.../new_shapes_p0/tpcds_sf100/rf_prune/query66.out | 103 +-
.../new_shapes_p0/tpcds_sf100/rf_prune/query74.out | 12 +-
.../new_shapes_p0/tpcds_sf100/rf_prune/query75.out | 4 +-
.../new_shapes_p0/tpcds_sf100/shape/query1.out | 10 +-
.../new_shapes_p0/tpcds_sf100/shape/query11.out | 12 +-
.../new_shapes_p0/tpcds_sf100/shape/query14.out | 79 +-
.../new_shapes_p0/tpcds_sf100/shape/query23.out | 18 +-
.../new_shapes_p0/tpcds_sf100/shape/query30.out | 4 +-
.../new_shapes_p0/tpcds_sf100/shape/query31.out | 20 +-
.../new_shapes_p0/tpcds_sf100/shape/query39.out | 4 +-
.../new_shapes_p0/tpcds_sf100/shape/query4.out | 20 +-
.../new_shapes_p0/tpcds_sf100/shape/query41.out | 2 +-
.../new_shapes_p0/tpcds_sf100/shape/query47.out | 8 +-
.../new_shapes_p0/tpcds_sf100/shape/query57.out | 8 +-
.../new_shapes_p0/tpcds_sf100/shape/query64.out | 4 +-
.../new_shapes_p0/tpcds_sf100/shape/query66.out | 103 +-
.../new_shapes_p0/tpcds_sf100/shape/query74.out | 12 +-
.../new_shapes_p0/tpcds_sf100/shape/query75.out | 4 +-
.../new_shapes_p0/tpcds_sf100/shape/query81.out | 4 +-
.../new_shapes_p0/tpcds_sf1000/shape/query1.out | 10 +-
.../new_shapes_p0/tpcds_sf1000/shape/query11.out | 12 +-
.../new_shapes_p0/tpcds_sf1000/shape/query14.out | 79 +-
.../new_shapes_p0/tpcds_sf1000/shape/query23.out | 18 +-
.../new_shapes_p0/tpcds_sf1000/shape/query30.out | 4 +-
.../new_shapes_p0/tpcds_sf1000/shape/query31.out | 20 +-
.../new_shapes_p0/tpcds_sf1000/shape/query39.out | 4 +-
.../new_shapes_p0/tpcds_sf1000/shape/query4.out | 20 +-
.../new_shapes_p0/tpcds_sf1000/shape/query41.out | 2 +-
.../new_shapes_p0/tpcds_sf1000/shape/query47.out | 8 +-
.../new_shapes_p0/tpcds_sf1000/shape/query57.out | 8 +-
.../new_shapes_p0/tpcds_sf1000/shape/query64.out | 4 +-
.../new_shapes_p0/tpcds_sf1000/shape/query66.out | 103 +-
.../new_shapes_p0/tpcds_sf1000/shape/query74.out | 16 +-
.../new_shapes_p0/tpcds_sf1000/shape/query75.out | 4 +-
.../new_shapes_p0/tpcds_sf1000/shape/query81.out | 4 +-
.../data/query_p0/aggregate/array_agg.out | 156 ++
.../query_p0/aggregate/test_array_agg_complex.csv | 112 +
.../test_array_aggregation_functions.out | 20 +-
.../test_array_functions_by_literal.out | 20 +-
.../cast_function/test_cast_map_function.out | 4 +-
.../datetime_functions/test_from_iso8601_date.out | 244 ++
.../datetime_functions/test_to_iso8601.out | 194 ++
.../encryption_digest/test_encryption_function.out | 3 +
.../sql_functions/json_functions/json_search.out | 139 ++
.../math_functions/test_least_greatest.out | 37 +-
.../math_functions/test_normal_cdf.out | 201 ++
.../string_functions/test_split_by_string.out | 4 +
.../string_functions/test_string_function.out | Bin 4590 -> 4838 bytes
.../string_functions/test_translate.out | 493 ++++
.../string_functions/test_url_decode.out | 43 +
.../string_functions/test_url_encode.out | 43 +
.../sql_functions/test_template_one_arg.out | 83 +
.../sql_functions/test_template_three_args.out | 471 ++++
.../sql_functions/test_template_two_args.out | 279 +++
.../window_functions/test_partition_topn.out | 5 +
.../query_p0/system/test_partitions_schema.out | 54 +-
.../data/query_p0/system/test_table_properties.out | 6 -
.../test_agg_schema_value_modify1.out | 11 +
.../show_p0/test_show_create_table_and_views.out | 46 -
.../unique_with_mow_c_p0/test_schema_change_ck.out | 341 +++
.../unique_with_mow_p0/partial_update/merge1.csv | 6 +
.../unique_with_mow_p0/partial_update/merge2.csv | 2 +
.../unique_with_mow_p0/partial_update/merge3.csv | 6 +
.../unique_with_mow_p0/partial_update/merge4.csv | 2 +
.../unique_with_mow_p0/partial_update/merge5.csv | 2 +
.../unique_with_mow_p0/partial_update/merge6.csv | 2 +
.../unique_with_mow_p0/partial_update/merge7.csv | 2 +
.../unique_with_mow_p0/partial_update/merge8.csv | 2 +
.../schema_change/load_with_key_column.csv | 2 +-
.../test_new_partial_update_delete.out | 52 -
.../test_partial_update_after_delete.out | 6 -
.../test_partial_update_auto_inc.out | 36 -
.../test_partial_update_case_insensitivity.out | 38 -
.../partial_update/test_partial_update_delete.out | 196 --
.../test_partial_update_merge_type.out | 341 +++
.../test_partial_update_mow_with_sync_mv.csv | 1 +
.../test_partial_update_native_insert_stmt.out | 12 -
.../test_partial_update_only_keys.out | 59 +
.../test_partial_update_seq_map_col.out | 95 +
.../data/update/test_unique_table_update.out | 10 -
regression-test/data/update/test_update_mow.out | 30 -
.../create_view_star_except_and_cast_to_sql.out | 4 +-
regression-test/data/view_p0/view_p0.out | 6 +
.../org/apache/doris/regression/Config.groovy | 3 +
.../apache/doris/regression/ConfigOptions.groovy | 7 +
.../apache/doris/regression/RegressionTest.groovy | 4 +
.../org/apache/doris/regression/suite/Suite.groovy | 155 +-
.../doris/regression/suite/SuiteCluster.groovy | 31 +-
.../doris/regression/suite/SuiteContext.groovy | 4 +-
.../apache/doris/regression/util/DebugPoint.groovy | 24 +
regression-test/java-udf-src/pom.xml | 2 +
.../pipeline/cloud_p0/conf/be_custom.conf | 3 +-
.../cloud_p0/conf/regression-conf-custom.groovy | 5 -
regression-test/pipeline/cloud_p0/run.sh | 3 +-
.../pipeline/cloud_p1/conf/be_custom.conf | 3 +-
regression-test/pipeline/common/github-utils.sh | 1 +
regression-test/pipeline/external/conf/be.conf | 3 +-
regression-test/pipeline/external/conf/fe.conf | 2 +-
regression-test/pipeline/p0/conf/be.conf | 3 +-
regression-test/pipeline/p1/conf/be.conf | 1 +
.../account_p0/test_nereids_row_policy.groovy | 20 +-
.../suites/audit/test_audit_log_behavior.groovy | 5 +-
.../auth_p0/test_http_meta_databases_auth.groovy | 58 +
.../auth_p0/test_http_meta_tables_auth.groovy | 70 +
.../test_http_meta_tables_schema_auth.groovy | 69 +
.../auth_p0/test_http_table_count_auth.groovy | 69 +
.../auth_p0/test_http_table_data_auth.groovy | 91 +
.../test_backup_restore_atomic_cancel.groovy | 128 ++
.../test_backup_restore_atomic_with_alter.groovy | 241 ++
.../test_backup_restore_atomic_with_view.groovy | 124 +
.../test_backup_restore_clean_restore.groovy | 36 +-
.../test_backup_restore_with_view.groovy | 17 +
.../test_insert_overwrite_recover.groovy | 64 +
.../check_before_quit/check_before_quit.groovy | 11 +
.../auth/test_grant_revoke_cluster_to_user.groovy | 4 +-
.../test_grant_revoke_compute_group_to_user.groovy | 299 +++
.../cache/http/test_calc_cache_file_hash.groovy | 56 +
.../cloud_p0/cache/http/test_reset_capacity.groovy | 2 +-
.../cluster/test_warm_up_compute_group.groovy | 265 +++
.../warm_up/hotspot/test_warmup_show_stmt_2.groovy | 8 +-
.../cloud_p0/multi_cluster/test_auto_start.groovy | 32 +-
.../multi_cluster/test_no_cluster_hits.groovy | 159 ++
.../suites/cloud_p0/multi_cluster/test_tvf.groovy | 2 +-
.../multi_cluster/test_warmup_rebalance.groovy | 2 +-
.../cloud_p0/node_mgr/test_not_allowed_op.groovy | 75 +
.../node_mgr/test_sql_mode_node_mgr.groovy | 495 ++++
.../compaction/test_compaction_uniq_keys_ck.groovy | 4 -
.../test_compaction_uniq_keys_row_store_ck.groovy | 4 -
...test_compaction_uniq_keys_with_delete_ck.groovy | 4 -
...paction_remove_old_version_delete_bitmap.groovy | 316 +++
.../suites/compaction/test_full_compaction.groovy | 6 +-
.../test_vertical_compaction_uniq_keys_ck.groovy | 4 -
.../correctness/test_column_nullable_cache.groovy | 57 +
.../test_scan_keys_with_bool_type.groovy | 110 +
..._nullable_window_function_legacy_planner.groovy | 174 --
.../suites/correctness_p0/test_cast_decimal.groovy | 1 -
.../correctness_p0/test_colocate_join.groovy | 311 ---
.../test_default_bitmap_empty.groovy | 137 ++
.../test_first_value_window_legacy_planner.groovy | 161 --
.../test_last_value_window_legacy_planner.groovy | 117 -
.../test_push_conjuncts_inlineview.groovy | 189 --
.../suites/correctness_p0/test_rand_filter.groovy | 1 -
.../test_runtimefilter_with_window.groovy | 38 -
.../correctness_p0/test_set_operation.groovy | 9 -
.../duplicate/storage/test_duplicate_bitmap.groovy | 52 +-
.../duplicate/storage/test_duplicate_hll.groovy | 76 +-
.../storage/test_duplicate_quantile_state.groovy | 68 +-
.../data_model_p0/unique/test_unique_bitmap.groovy | 38 +-
.../data_model_p0/unique/test_unique_hll.groovy | 76 +-
.../unique/test_unique_quantile_state.groovy | 68 +-
.../unique/test_unique_table_auto_inc.groovy | 15 -
.../datatype_p0/datetimev2/test_timezone.groovy | 19 -
.../datatype_p0/decimalv3/test_decimalv3.groovy | 16 -
.../suites/datatype_p0/decimalv3/test_load.groovy | 1 -
.../test_array_functions_array_with_const.groovy | 33 -
.../test_array_zip_array_enumerate_uniq.groovy | 72 +-
.../query/map_functions/test_map_with_agg.groovy | 7 -
.../get_assignment_compatible_type.groovy | 1 -
.../ddl_p0/test_create_or_replace_view.groovy | 62 +
...est_create_table_generated_column_legacy.groovy | 249 --
.../test_delete_generated_column.groovy | 16 +-
.../ddl_p0/test_create_table_like_nereids.groovy | 7 +-
.../test_create_table_without_distribution.groovy | 1 -
.../suites/ddl_p0/test_create_view.groovy | 237 --
.../delete_p0/fold_constant/fold_constant.groovy | 1 -
.../suites/delete_p0/test_delete.groovy | 2 -
.../suites/delete_p0/test_delete_on_mor.groovy | 51 +-
.../delete_p0/test_delete_with_sync_mv.groovy | 4 +
.../suites/demo_p0/explain_action.groovy | 9 +-
.../export_p2/test_export_max_file_size.groovy | 65 +-
.../test_outfile_orc_max_file_size.groovy | 69 +-
.../suites/export_p2/test_outfile_p2.groovy | 37 +-
.../hive/ddl/test_hive_ddl.groovy | 36 +-
.../hive/ddl/test_hive_write_type.groovy | 2 +-
.../hive/test_hive_partition_values_tvf.groovy | 142 ++
.../hive/test_hive_partitions.groovy | 11 +-
.../hive/test_hms_event_notification.groovy | 2 +-
...est_hms_event_notification_multi_catalog.groovy | 2 +-
...t_hive_insert_overwrite_with_empty_table.groovy | 11 +-
.../iceberg/write/test_iceberg_create_table.groovy | 91 +-
.../jdbc/test_doris_jdbc_catalog.groovy | 4 +
.../jdbc/test_gbase_jdbc_catalog.groovy | 137 ++
.../jdbc/test_jdbc_catalog_ddl.groovy | 73 +
.../jdbc/test_jdbc_query_mysql.groovy | 2 +-
.../jdbc/test_jdbc_query_pg.groovy | 2 +-
.../jdbc/test_mysql_jdbc_catalog.groovy | 9 -
.../kerberos/test_single_hive_kerberos.groovy | 6 +-
.../paimon/paimon_tb_mix_format.groovy | 56 +
.../external_table_p0/tvf/test_hdfs_tvf.groovy | 26 +
.../tvf/test_tvf_view_count.groovy | 1 -
.../external_table_p0/tvf/upgrade/load.groovy | 55 +
.../external_table_p0/tvf/upgrade/test.groovy | 34 +
.../es/test_external_catalog_es.groovy | 5 +
.../hive/test_cloud_accessible_obs.groovy | 6 +
.../hive/test_cloud_accessible_oss.groovy | 7 +
.../hive/test_external_brown.groovy | 5 +
.../hive/test_external_catalog_glue_table.groovy | 7 +
.../hive/test_external_github.groovy | 5 +
.../hive/test_external_yandex.groovy | 87 -
.../hive/test_external_yandex_nereids.groovy | 5 +
.../external_table_p2/hive/test_hive_hudi.groovy | 6 +
.../hive/test_hive_hudi_statistics.groovy | 6 +
.../hive/test_hive_partition_statistic.groovy | 5 +
.../hive/test_hive_statistic_cache.groovy | 6 +
.../hive/test_hive_statistic_sample.groovy | 5 +
.../hive/test_hive_write_insert_s3.groovy | 6 +
.../hive/test_select_count_optimize.groovy | 7 +
.../hive/test_upper_case_column_name.groovy | 6 +
.../external_table_p2/hive/test_viewfs_hive.groovy | 5 +
.../hudi/test_hudi_timetravel.groovy | 6 +
.../test_external_catalog_maxcompute.groovy | 15 +-
.../mysql/test_external_catalog_mysql.groovy | 6 +
.../mysql/test_external_resource_mysql.groovy | 6 +
.../test_external_resource_mysql_nereids.groovy | 156 --
.../external_table_p2/pg/test_external_pg.groovy | 133 --
.../pg/test_external_pg_nereids.groovy | 6 +
.../external_table_p2/tvf/test_iceberg_meta.groovy | 9 +-
.../test_cloud_mow_broker_load_with_retry.groovy | 251 ++
.../cloud/test_cloud_mow_insert_timeout.groovy | 2 +-
.../cloud/test_cloud_mow_insert_with_retry.groovy | 76 +
.../test_delete_publish_skip_read.groovy | 2 +-
.../test_disable_move_memtable.groovy | 18 -
.../test_iot_auto_detect_concurrent.groovy | 14 +-
.../group_commit/test_group_commit_error.groovy | 3 -
.../insert_p0/insert_group_commit_into.groovy | 500 ++--
...nsert_group_commit_into_max_filter_ratio.groovy | 94 +-
.../insert_group_commit_into_unique.groovy | 369 ++-
...nsert_group_commit_into_unique_sync_mode.groovy | 364 ++-
.../insert_group_commit_with_exception.groovy | 351 ++-
.../insert_group_commit_with_large_data.groovy | 64 +-
.../suites/insert_p0/insert_with_null.groovy | 9 +-
.../test_group_commit_data_bytes_property.groovy | 52 +-
.../test_group_commit_interval_ms_property.groovy | 28 +-
.../test_insert_partition_fail_url.groovy | 11 +-
.../insert_p0/test_insert_strict_fail_url.groovy | 11 +-
.../suites/insert_p0/transaction/txn_insert.groovy | 1 +
.../txn_insert_with_specify_columns.groovy | 54 -
...ommit_http_stream_lineitem_schema_change.groovy | 2 +
...ommit_insert_into_lineitem_scheme_change.groovy | 2 +
...ommit_stream_load_lineitem_schema_change.groovy | 2 +
.../txn_insert_concurrent_insert_ud.groovy | 1 +
.../txn_insert_concurrent_insert_update.groovy | 1 +
.../insert_p2/txn_insert_with_schema_change.groovy | 1 +
.../inverted_index_p0/test_count_on_index.groovy | 41 +-
.../test_index_no_need_read_data.groovy | 18 -
.../jsonb_p0/test_jsonb_load_and_function.groovy | 9 -
.../insert/test_insert_default_value.groovy | 14 -
.../load_p2/broker_load/test_broker_load.groovy | 3 +-
.../suites/manager/test_manager_interface_1.groovy | 59 +-
.../same_column_name_check.groovy | 101 +
.../suites/mtmv_p0/test_alter_job_mtmv.groovy | 67 +
...ble_date_non_deterministic_function_mtmv.groovy | 6 +-
.../suites/mtmv_p0/test_storage_medium_mtmv.groovy | 2 +
.../test_duplicate_mv/test_duplicate_mv.groovy | 48 +
.../agg_function/test_covar_samp.groovy | 2 +-
.../suites/nereids_function_p0/load.groovy | 23 +
.../scalar_function/Array.groovy | 42 +
.../nereids_function_p0/scalar_function/R.groovy | 2 +
.../nereids_p0/cte/test_cte_filter_pushdown.groovy | 1 +
.../fold_constant/fold_constant_by_be.groovy | 5 +
.../fold_constant_string_arithmatic.groovy | 98 +-
.../suites/nereids_p0/hint/multi_leading.groovy | 186 +-
.../suites/nereids_p0/hint/test_hint.groovy | 16 +-
.../suites/nereids_p0/hint/test_use_mv.groovy | 10 +-
.../nereids_p0/insert_into_table/random.groovy | 11 +
.../test_aggregate_window_functions.groovy | 522 +++++
.../datetime_functions/test_date_function.groovy | 9 +-
.../sql_functions/math_functions/test_conv.groovy | 10 +
.../string_functions/test_split_part.groovy | 5 +
.../string_functions/test_string_function.groovy | 23 +
.../subquery/correlated_scalar_subquery.groovy | 223 ++
.../nereids_p0/subquery/test_subquery.groovy | 2 +
.../suites/nereids_p0/system/test_query_sys.groovy | 8 -
.../cte/test_cte_filter_pushdown.groovy | 1 +
.../eliminate_outer_join.groovy | 1 +
.../test_simplify_decimal_comparison.groovy | 28 +
.../grouping_sets/valid_grouping.groovy | 54 -
.../availability/materialized_view_switch.groovy | 4 +-
.../mv/dimension/dimension_self_conn.groovy | 2 +-
.../union_all_compensate.groovy | 345 +++
.../mv/union_rewrite/usercase_union_rewrite.groovy | 4 +-
.../mv/with_auth/with_select_table_auth.groovy | 184 ++
.../normalize_window_nullable_agg_test.groovy | 75 +
.../test_date_function_prune.groovy | 12 +-
.../extract_from_disjunction_in_join.groovy | 6 +-
.../distribute/distribution_expr.groovy | 6 +-
.../mv/aggregate/agg_sync_mv.groovy | 51 +-
.../nereids_syntax_p0/window_function.groovy | 39 +
.../mv/aggregate/agg_sync_mv.groovy | 0
.../mv/load.groovy | 0
.../suites/nereids_tpch_p0/tpch/agg_cse.groovy | 100 +
.../suites/nereids_tpch_p0/tpch/topn_filter.groovy | 1 +
regression-test/suites/node_p0/test_backend.groovy | 11 +-
.../suites/node_p0/test_frontend.groovy | 4 +
.../auto_partition/test_auto_dynamic.groovy | 21 +-
.../test_dynamic_partition.groovy | 5 +-
...t_dynamic_partition_mod_distribution_key.groovy | 2 +-
.../suites/point_query_p0/test_rowstore.groovy | 1 +
.../suites/prepared_stmt_p0/prepared_stmt.groovy | 4 -
.../suites/query_p0/aggregate/array_agg.groovy | 27 +
.../aggregate/select_random_distributed_tbl.groovy | 92 +-
regression-test/suites/query_p0/dual/dual.groovy | 8 -
.../limit/test_map_select_with_limit.groovy | 2 +-
.../test_array_functions_by_literal.groovy | 28 +-
.../cast_function/test_cast_map_function.groovy | 1 -
.../conditional_functions/test_coalesce_new.groovy | 45 -
.../test_from_iso8601_date.groovy | 149 ++
.../datetime_functions/test_to_iso8601.groovy | 148 ++
.../test_encryption_function.groovy | 3 +
.../json_functions/json_search.groovy | 121 +
.../test_mapagg_with_jsonfuncs.groovy | 3 -
.../math_functions/test_normal_cdf.groovy | 93 +
.../size_funciton/test_size_function.groovy | 1 -
.../string_functions/test_split_by_string.groovy | 2 +
.../string_functions/test_string_function.groovy | 10 +
.../string_functions/test_translate.groovy | 125 +
.../string_functions/test_url_decode.groovy | 47 +
.../string_functions/test_url_encode.groovy | 47 +
.../sql_functions/test_template_one_arg.groovy | 51 +
.../sql_functions/test_template_three_args.groovy | 114 +
.../sql_functions/test_template_two_args.groovy | 108 +
.../window_functions/test_partition_topn.groovy | 66 +
.../test_select_stddev_variance_window.groovy | 12 -
.../query_p0/system/test_partitions_schema.groovy | 14 +-
.../suites/query_p0/system/test_query_sys.groovy | 2 +
.../query_p0/system/test_table_properties.groovy | 10 +-
.../query_p0/test_array_orderby_limit.groovy | 2 +-
.../suites/query_p0/test_forward_qeury.groovy | 6 +-
.../suites/query_p0/test_row_policy.groovy | 5 -
...ptive_pipeline_task_serial_read_on_limit.groovy | 4 +-
.../suites/rollup_p0/test_rollup_add_column.groovy | 33 +-
.../suites/rollup_p0/test_rollup_agg_date.groovy | 32 +-
.../test_schema_change_concurrent_with_txn.groovy | 1 +
.../test_agg_schema_value_modify1.groovy | 2401 ++++++++++++++++++++
.../test_agg_schema_value_modify4.groovy | 1089 +++++++++
.../test_show_create_table_and_views.groovy | 150 --
.../suites/statistics/test_analyze_mtmv.groovy | 9 +-
.../suites/statistics/test_analyze_mv.groovy | 123 +-
.../statistics/test_drop_stats_and_truncate.groovy | 228 ++
.../suites/statistics/test_partition_stats.groovy | 48 +-
...est_create_table_if_not_exists_as_select.groovy | 3 -
.../suites/tpch_sf100_p2/ddl/customer.sql | 1 +
.../suites/tpch_sf100_p2/ddl/lineitem.sql | 1 +
.../suites/tpch_sf100_p2/ddl/nation.sql | 1 +
.../suites/tpch_sf100_p2/ddl/orders.sql | 1 +
regression-test/suites/tpch_sf100_p2/ddl/part.sql | 1 +
.../suites/tpch_sf100_p2/ddl/partsupp.sql | 1 +
.../suites/tpch_sf100_p2/ddl/region.sql | 1 +
.../suites/tpch_sf100_p2/ddl/supplier.sql | 1 +
.../suites/tpch_sf100_unique_p2/ddl/customer.sql | 1 +
.../tpch_sf100_unique_p2/ddl/customer_sequence.sql | 1 +
.../suites/tpch_sf100_unique_p2/ddl/lineitem.sql | 1 +
.../tpch_sf100_unique_p2/ddl/lineitem_sequence.sql | 1 +
.../suites/tpch_sf100_unique_p2/ddl/nation.sql | 1 +
.../tpch_sf100_unique_p2/ddl/nation_sequence.sql | 1 +
.../suites/tpch_sf100_unique_p2/ddl/orders.sql | 1 +
.../tpch_sf100_unique_p2/ddl/orders_sequence.sql | 1 +
.../suites/tpch_sf100_unique_p2/ddl/part.sql | 1 +
.../tpch_sf100_unique_p2/ddl/part_sequence.sql | 1 +
.../suites/tpch_sf100_unique_p2/ddl/partsupp.sql | 1 +
.../tpch_sf100_unique_p2/ddl/partsupp_sequence.sql | 1 +
.../suites/tpch_sf100_unique_p2/ddl/region.sql | 1 +
.../tpch_sf100_unique_p2/ddl/region_sequence.sql | 1 +
.../suites/tpch_sf100_unique_p2/ddl/supplier.sql | 1 +
.../tpch_sf100_unique_p2/ddl/supplier_sequence.sql | 1 +
.../tpch_sf100_unique_sql_p2/ddl/customer.sql | 1 +
.../tpch_sf100_unique_sql_p2/ddl/lineitem.sql | 1 +
.../suites/tpch_sf100_unique_sql_p2/ddl/nation.sql | 1 +
.../suites/tpch_sf100_unique_sql_p2/ddl/orders.sql | 1 +
.../suites/tpch_sf100_unique_sql_p2/ddl/part.sql | 1 +
.../tpch_sf100_unique_sql_p2/ddl/partsupp.sql | 1 +
.../suites/tpch_sf100_unique_sql_p2/ddl/region.sql | 1 +
.../tpch_sf100_unique_sql_p2/ddl/supplier.sql | 1 +
.../suites/tpch_sf10_unique_p2/ddl/customer.sql | 1 +
.../tpch_sf10_unique_p2/ddl/customer_sequence.sql | 1 +
.../suites/tpch_sf10_unique_p2/ddl/lineitem.sql | 1 +
.../tpch_sf10_unique_p2/ddl/lineitem_sequence.sql | 1 +
.../suites/tpch_sf10_unique_p2/ddl/nation.sql | 1 +
.../tpch_sf10_unique_p2/ddl/nation_sequence.sql | 1 +
.../suites/tpch_sf10_unique_p2/ddl/orders.sql | 1 +
.../tpch_sf10_unique_p2/ddl/orders_sequence.sql | 1 +
.../suites/tpch_sf10_unique_p2/ddl/part.sql | 1 +
.../tpch_sf10_unique_p2/ddl/part_sequence.sql | 1 +
.../suites/tpch_sf10_unique_p2/ddl/partsupp.sql | 1 +
.../tpch_sf10_unique_p2/ddl/partsupp_sequence.sql | 1 +
.../suites/tpch_sf10_unique_p2/ddl/region.sql | 1 +
.../tpch_sf10_unique_p2/ddl/region_sequence.sql | 1 +
.../suites/tpch_sf10_unique_p2/ddl/supplier.sql | 1 +
.../tpch_sf10_unique_p2/ddl/supplier_sequence.sql | 1 +
.../suites/tpch_sf1_p2/ddl/create_table.sql | 1 +
.../suites/tpch_sf1_p2/ddl/customer.sql | 1 +
.../suites/tpch_sf1_p2/ddl/lineitem.sql | 1 +
regression-test/suites/tpch_sf1_p2/ddl/nation.sql | 1 +
regression-test/suites/tpch_sf1_p2/ddl/orders.sql | 1 +
regression-test/suites/tpch_sf1_p2/ddl/part.sql | 1 +
.../suites/tpch_sf1_p2/ddl/partsupp.sql | 1 +
regression-test/suites/tpch_sf1_p2/ddl/region.sql | 1 +
.../suites/tpch_sf1_p2/ddl/supplier.sql | 1 +
.../suites/tpch_sf1_unique_p2/ddl/customer.sql | 1 +
.../suites/tpch_sf1_unique_p2/ddl/lineitem.sql | 1 +
.../suites/tpch_sf1_unique_p2/ddl/nation.sql | 1 +
.../suites/tpch_sf1_unique_p2/ddl/orders.sql | 1 +
.../suites/tpch_sf1_unique_p2/ddl/part.sql | 1 +
.../suites/tpch_sf1_unique_p2/ddl/partsupp.sql | 1 +
.../suites/tpch_sf1_unique_p2/ddl/region.sql | 1 +
.../suites/tpch_sf1_unique_p2/ddl/supplier.sql | 1 +
regression-test/suites/trash_p0/clean_trash.groovy | 11 +-
.../unique_with_mow_c_p0/test_create_table.groovy | 23 +-
.../unique_with_mow_c_p0/test_schema_change.groovy | 6 +-
.../test_schema_change_ck.groovy | 264 +++
.../ssb_unique_load_zstd/ddl/customer_create.sql | 1 +
.../ddl/customer_sequence_create.sql | 1 +
.../ssb_unique_load_zstd/ddl/date_create.sql | 1 +
.../ddl/date_sequence_create.sql | 1 +
.../ssb_unique_load_zstd/ddl/lineorder_create.sql | 1 +
.../ddl/lineorder_sequence_create.sql | 1 +
.../ssb_unique_load_zstd/ddl/part_create.sql | 1 +
.../ddl/part_sequence_create.sql | 1 +
.../ssb_unique_load_zstd/ddl/supplier_create.sql | 1 +
.../ddl/supplier_sequence_create.sql | 1 +
.../ssb_unique_sql_zstd/ddl/customer_create.sql | 1 +
.../ssb_unique_sql_zstd/ddl/date_create.sql | 1 +
.../ssb_unique_sql_zstd/ddl/lineorder_create.sql | 1 +
.../ssb_unique_sql_zstd/ddl/part_create.sql | 1 +
.../ssb_unique_sql_zstd/ddl/supplier_create.sql | 1 +
.../test_new_partial_update_delete.groovy | 114 -
.../test_partial_update_after_delete.groovy | 28 -
.../test_partial_update_auto_inc.groovy | 148 +-
.../test_partial_update_case_insensitivity.groovy | 50 +-
.../test_partial_update_delete.groovy | 268 ++-
...artial_update_insert_light_schema_change.groovy | 4 +-
...test_partial_update_insert_schema_change.groovy | 4 +-
.../test_partial_update_merge_type.groovy | 185 ++
.../test_partial_update_mow_with_sync_mv.groovy | 103 +
.../test_partial_update_native_insert_stmt.groovy | 53 +-
.../test_partial_update_only_keys.groovy | 62 +
.../test_partial_update_schema_change.groovy | 8 +-
...t_partial_update_schema_change_row_store.groovy | 8 +-
.../test_partial_update_seq_map_col.groovy | 146 ++
.../ssb_unique_load_zstd/ddl/customer_create.sql | 1 +
.../ddl/customer_sequence_create.sql | 1 +
.../ssb_unique_load_zstd/ddl/date_create.sql | 1 +
.../ddl/date_sequence_create.sql | 1 +
.../ssb_unique_load_zstd/ddl/lineorder_create.sql | 1 +
.../ddl/lineorder_sequence_create.sql | 1 +
.../ssb_unique_load_zstd/ddl/part_create.sql | 1 +
.../ddl/part_sequence_create.sql | 1 +
.../ssb_unique_load_zstd/ddl/supplier_create.sql | 1 +
.../ddl/supplier_sequence_create.sql | 1 +
.../ssb_unique_sql_zstd/ddl/customer_create.sql | 1 +
.../ssb_unique_sql_zstd/ddl/date_create.sql | 1 +
.../ssb_unique_sql_zstd/ddl/lineorder_create.sql | 1 +
.../ssb_unique_sql_zstd/ddl/part_create.sql | 1 +
.../ssb_unique_sql_zstd/ddl/supplier_create.sql | 1 +
.../suites/update/test_unique_table_update.groovy | 23 -
.../suites/update/test_update_mow.groovy | 62 -
.../suites/variant_github_events_p2/load.groovy | 1 +
.../suites/variant_p0/column_name.groovy | 2 -
regression-test/suites/variant_p0/load.groovy | 16 +
regression-test/suites/variant_p0/nested.groovy | 2 +-
.../suites/variant_p0/variant_with_rowstore.groovy | 1 -
.../create_view_star_except_and_cast_to_sql.groovy | 1 -
regression-test/suites/view_p0/view_p0.groovy | 11 +-
.../test_workload_sched_policy.groovy | 2 -
tools/fdb/fdb_ctl.sh | 151 +-
tools/fdb/fdb_vars.sh | 35 +-
1405 files changed, 45276 insertions(+), 26611 deletions(-)
create mode 100644 be/src/cloud/cloud_delete_bitmap_action.cpp
create mode 100644 be/src/cloud/cloud_delete_bitmap_action.h
create mode 100644 be/src/http/action/load_channel_action.cpp
create mode 100644 be/src/http/action/load_channel_action.h
create mode 100644 be/src/io/cache/mem_file_cache_storage.cpp
create mode 100644 be/src/io/cache/mem_file_cache_storage.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/analyzer/analyzer.cpp
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/analyzer/analyzer.h
create mode 100644 be/src/runtime/memory/mem_counter.h
create mode 100644 be/src/util/algorithm_util.h
create mode 100644 be/src/vec/functions/array/varray_match_function.cpp
create mode 100644 be/src/vec/functions/date_format_type.h
create mode 100644 be/test/olap/delta_writer_cluster_key_test.cpp
create mode 100644 be/test/util/algo_util_test.cpp
create mode 100644 be/test/vec/columns/column_nullable_test.cpp
create mode 100644 be/test/vec/columns/column_nullable_test.h
create mode 100644 be/test/vec/core/column_test.cpp
create mode 100644 be/test/vec/function/function_test_template.cpp
create mode 100644
docker/thirdparties/docker-compose/hive/hadoop-hive-2x.env.tpl
create mode 100644
docker/thirdparties/docker-compose/hive/hadoop-hive-3x.env.tpl
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/create_preinstalled_scripts/run06.sql
create mode 100644
fe/be-java-extensions/jdbc-scanner/src/main/java/org/apache/doris/jdbc/GbaseJdbcExecutor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/cloud/qe/ComputeGroupException.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/common/RandomIdentifierGenerator.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/client/JdbcGbaseClient.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mysql/privilege/RangerDorisAccessControllerFactory.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/ProjectAggregateExpressionsForCse.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/NormalizeGenerate.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/NoneMovableFunction.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/ArrayMatchAll.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/ArrayMatchAny.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/FromIso8601Date.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/JsonSearch.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/LastQueryId.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/NormalCdf.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/ToIso8601.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/Translate.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/UrlEncode.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/table/PartitionValues.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/NotAllowFallback.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plugin/PropertiesUtils.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/tablefunction/PartitionValuesTableValuedFunction.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/transaction/AbstractExternalTransactionManager.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/transaction/GlobalExternalTransactionInfoMgr.java
create mode 100644
fe/fe-core/src/main/resources/META-INF/services/org.apache.doris.mysql.privilege.AccessControllerFactory
delete mode 100755
fe/fe-core/src/test/java/org/apache/doris/analysis/SelectStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/StmtRewriterTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/hive/HiveMetaStoreCacheTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/insertoverwrite/InsertOverwriteManagerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/memo/GroupExpressionTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/mv/MtmvCacheNewConnectContextTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/preprocess/SelectHintTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/privileges/CustomAccessControllerFactory.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/AdjustNullableTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/ColocatePlanTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/DistributedPlannerTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/PlannerTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/ProjectPlannerFunctionTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/QueryPlanTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/RepeatNodeTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/TableFunctionPlanTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/rewrite/ExtractCommonFactorsRuleFunctionTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/rewrite/InferFiltersRuleTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/rewrite/RewriteBinaryPredicatesRuleTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/rewrite/RewriteInPredicateRuleTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/statistics/StatsDeriveResultTest.java
create mode 100644
fe/fe-core/src/test/resources/META-INF/services/org.apache.doris.mysql.privilege.AccessControllerFactory
create mode 100644
regression-test/data/backup_restore/test_backup_restore_atomic_with_view.out
create mode 100644
regression-test/data/catalog_recycle_bin_p0/test_insert_overwrite_recover.out
create mode 100644
regression-test/data/compaction/test_cu_compaction_remove_old_version_delete_bitmap.out
create mode 100644
regression-test/data/correctness/test_column_nullable_cache.out
create mode 100644
regression-test/data/correctness/test_scan_keys_with_bool_type.out
delete mode 100644
regression-test/data/correctness_p0/test_always_nullable_window_function_legacy_planner.out
delete mode 100644 regression-test/data/correctness_p0/test_colocate_join.out
create mode 100644
regression-test/data/correctness_p0/test_default_bitmap_empty.out
copy regression-test/data/correctness_p0/{test_default_hll_streamload.csv =>
test_default_bitmap_empty_streamload.csv} (100%)
delete mode 100644
regression-test/data/correctness_p0/test_first_value_window_legacy_planner.out
delete mode 100644
regression-test/data/correctness_p0/test_last_value_window_legacy_planner.out
create mode 100644 regression-test/data/ddl_p0/test_create_or_replace_view.out
delete mode 100644
regression-test/data/ddl_p0/test_create_table_generated_column/test_create_table_generated_column_legacy.out
delete mode 100644 regression-test/data/ddl_p0/test_create_view.out
create mode 100644
regression-test/data/external_table_p0/hive/test_hive_partition_values_tvf.out
create mode 100644
regression-test/data/external_table_p0/jdbc/test_gbase_jdbc_catalog.out
create mode 100644
regression-test/data/external_table_p0/jdbc/test_jdbc_catalog_ddl.out
create mode 100644
regression-test/data/external_table_p0/paimon/paimon_tb_mix_format.out
create mode 100644 regression-test/data/external_table_p0/tvf/upgrade/test.out
create mode 100644
regression-test/data/fault_injection_p0/cloud/test_cloud_mow_broker_load_with_retry.out
create mode 100644
regression-test/data/fault_injection_p0/cloud/test_cloud_mow_insert_with_retry.out
create mode 100644
regression-test/data/insert_p0/group_commit/replay_wal_restart_fe.out
create mode 100644 regression-test/data/inverted_index_p0/count-on-index.json
create mode 100644
regression-test/data/mv_p0/test_duplicate_mv/test_duplicate_mv.out
create mode 100644 regression-test/data/nereids_function_p0/fn_test_am.csv
create mode 100644
regression-test/data/nereids_p0/sql_functions/aggregate_functions/test_aggregate_window_functions.out
create mode 100644
regression-test/data/nereids_p0/subquery/correlated_scalar_subquery.out
create mode 100644
regression-test/data/nereids_rules_p0/mv/union_all_compensate/union_all_compensate.out
create mode 100644
regression-test/data/nereids_rules_p0/normalize_window/normalize_window_nullable_agg_test.out
copy regression-test/data/{nereids_syntax_p0 =>
nereids_syntax_p1}/mv/agg_mv_test.dat (100%)
create mode 100644
regression-test/data/nereids_syntax_p1/mv/aggregate/agg_sync_mv.out
create mode 100644 regression-test/data/nereids_tpch_p0/tpch/agg_cse.out
create mode 100644
regression-test/data/query_p0/aggregate/test_array_agg_complex.csv
create mode 100644
regression-test/data/query_p0/sql_functions/datetime_functions/test_from_iso8601_date.out
create mode 100644
regression-test/data/query_p0/sql_functions/datetime_functions/test_to_iso8601.out
create mode 100644
regression-test/data/query_p0/sql_functions/json_functions/json_search.out
create mode 100644
regression-test/data/query_p0/sql_functions/math_functions/test_normal_cdf.out
create mode 100644
regression-test/data/query_p0/sql_functions/string_functions/test_translate.out
create mode 100644
regression-test/data/query_p0/sql_functions/string_functions/test_url_decode.out
create mode 100644
regression-test/data/query_p0/sql_functions/string_functions/test_url_encode.out
create mode 100644
regression-test/data/query_p0/sql_functions/test_template_one_arg.out
create mode 100644
regression-test/data/query_p0/sql_functions/test_template_three_args.out
create mode 100644
regression-test/data/query_p0/sql_functions/test_template_two_args.out
create mode 100644
regression-test/data/query_p0/sql_functions/window_functions/test_partition_topn.out
create mode 100644
regression-test/data/schema_change_p0/test_agg_schema_value_modify1.out
delete mode 100644
regression-test/data/show_p0/test_show_create_table_and_views.out
create mode 100644
regression-test/data/unique_with_mow_c_p0/test_schema_change_ck.out
create mode 100644
regression-test/data/unique_with_mow_p0/partial_update/merge1.csv
create mode 100644
regression-test/data/unique_with_mow_p0/partial_update/merge2.csv
create mode 100644
regression-test/data/unique_with_mow_p0/partial_update/merge3.csv
create mode 100644
regression-test/data/unique_with_mow_p0/partial_update/merge4.csv
create mode 100644
regression-test/data/unique_with_mow_p0/partial_update/merge5.csv
create mode 100644
regression-test/data/unique_with_mow_p0/partial_update/merge6.csv
create mode 100644
regression-test/data/unique_with_mow_p0/partial_update/merge7.csv
create mode 100644
regression-test/data/unique_with_mow_p0/partial_update/merge8.csv
create mode 100644
regression-test/data/unique_with_mow_p0/partial_update/test_partial_update_merge_type.out
create mode 100644
regression-test/data/unique_with_mow_p0/partial_update/test_partial_update_mow_with_sync_mv.csv
create mode 100644
regression-test/data/unique_with_mow_p0/partial_update/test_partial_update_only_keys.out
create mode 100644
regression-test/data/unique_with_mow_p0/partial_update/test_partial_update_seq_map_col.out
create mode 100644
regression-test/suites/auth_p0/test_http_meta_databases_auth.groovy
create mode 100644
regression-test/suites/auth_p0/test_http_meta_tables_auth.groovy
create mode 100644
regression-test/suites/auth_p0/test_http_meta_tables_schema_auth.groovy
create mode 100644
regression-test/suites/auth_p0/test_http_table_count_auth.groovy
create mode 100644
regression-test/suites/auth_p0/test_http_table_data_auth.groovy
create mode 100644
regression-test/suites/backup_restore/test_backup_restore_atomic_cancel.groovy
create mode 100644
regression-test/suites/backup_restore/test_backup_restore_atomic_with_alter.groovy
create mode 100644
regression-test/suites/backup_restore/test_backup_restore_atomic_with_view.groovy
create mode 100644
regression-test/suites/catalog_recycle_bin_p0/test_insert_overwrite_recover.groovy
create mode 100644
regression-test/suites/cloud_p0/auth/test_grant_revoke_compute_group_to_user.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/http/test_calc_cache_file_hash.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/cluster/test_warm_up_compute_group.groovy
create mode 100644
regression-test/suites/cloud_p0/multi_cluster/test_no_cluster_hits.groovy
create mode 100644
regression-test/suites/cloud_p0/node_mgr/test_not_allowed_op.groovy
create mode 100644
regression-test/suites/cloud_p0/node_mgr/test_sql_mode_node_mgr.groovy
create mode 100644
regression-test/suites/compaction/test_cu_compaction_remove_old_version_delete_bitmap.groovy
create mode 100644
regression-test/suites/correctness/test_column_nullable_cache.groovy
create mode 100644
regression-test/suites/correctness/test_scan_keys_with_bool_type.groovy
delete mode 100644
regression-test/suites/correctness_p0/test_always_nullable_window_function_legacy_planner.groovy
delete mode 100644
regression-test/suites/correctness_p0/test_colocate_join.groovy
create mode 100644
regression-test/suites/correctness_p0/test_default_bitmap_empty.groovy
delete mode 100644
regression-test/suites/correctness_p0/test_first_value_window_legacy_planner.groovy
delete mode 100644
regression-test/suites/correctness_p0/test_last_value_window_legacy_planner.groovy
delete mode 100644
regression-test/suites/correctness_p0/test_push_conjuncts_inlineview.groovy
create mode 100644
regression-test/suites/ddl_p0/test_create_or_replace_view.groovy
delete mode 100644
regression-test/suites/ddl_p0/test_create_table_generated_column/test_create_table_generated_column_legacy.groovy
delete mode 100644 regression-test/suites/ddl_p0/test_create_view.groovy
create mode 100644
regression-test/suites/external_table_p0/hive/test_hive_partition_values_tvf.groovy
create mode 100644
regression-test/suites/external_table_p0/jdbc/test_gbase_jdbc_catalog.groovy
create mode 100644
regression-test/suites/external_table_p0/jdbc/test_jdbc_catalog_ddl.groovy
create mode 100644
regression-test/suites/external_table_p0/paimon/paimon_tb_mix_format.groovy
create mode 100644
regression-test/suites/external_table_p0/tvf/upgrade/load.groovy
create mode 100644
regression-test/suites/external_table_p0/tvf/upgrade/test.groovy
delete mode 100644
regression-test/suites/external_table_p2/hive/test_external_yandex.groovy
delete mode 100644
regression-test/suites/external_table_p2/mysql/test_external_resource_mysql_nereids.groovy
delete mode 100644
regression-test/suites/external_table_p2/pg/test_external_pg.groovy
create mode 100644
regression-test/suites/fault_injection_p0/cloud/test_cloud_mow_broker_load_with_retry.groovy
create mode 100644
regression-test/suites/fault_injection_p0/cloud/test_cloud_mow_insert_with_retry.groovy
create mode 100644
regression-test/suites/mtmv_p0/same_column_name_check/same_column_name_check.groovy
create mode 100644 regression-test/suites/mtmv_p0/test_alter_job_mtmv.groovy
create mode 100644
regression-test/suites/mv_p0/test_duplicate_mv/test_duplicate_mv.groovy
create mode 100644
regression-test/suites/nereids_p0/sql_functions/aggregate_functions/test_aggregate_window_functions.groovy
create mode 100644
regression-test/suites/nereids_p0/subquery/correlated_scalar_subquery.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/expression/test_simplify_decimal_comparison.groovy
delete mode 100644
regression-test/suites/nereids_rules_p0/grouping_sets/valid_grouping.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/union_all_compensate/union_all_compensate.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/with_auth/with_select_table_auth.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/normalize_window/normalize_window_nullable_agg_test.groovy
copy regression-test/suites/{nereids_syntax_p0 =>
nereids_syntax_p1}/mv/aggregate/agg_sync_mv.groovy (100%)
copy regression-test/suites/{nereids_syntax_p0 =>
nereids_syntax_p1}/mv/load.groovy (100%)
create mode 100644 regression-test/suites/nereids_tpch_p0/tpch/agg_cse.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/datetime_functions/test_from_iso8601_date.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/datetime_functions/test_to_iso8601.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/json_functions/json_search.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/math_functions/test_normal_cdf.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/string_functions/test_translate.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/string_functions/test_url_decode.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/string_functions/test_url_encode.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/test_template_one_arg.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/test_template_three_args.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/test_template_two_args.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/window_functions/test_partition_topn.groovy
create mode 100644
regression-test/suites/schema_change_p0/test_agg_schema_value_modify1.groovy
create mode 100644
regression-test/suites/schema_change_p0/test_agg_schema_value_modify4.groovy
delete mode 100644
regression-test/suites/show_p0/test_show_create_table_and_views.groovy
create mode 100644
regression-test/suites/statistics/test_drop_stats_and_truncate.groovy
create mode 100644
regression-test/suites/unique_with_mow_c_p0/test_schema_change_ck.groovy
create mode 100644
regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_merge_type.groovy
create mode 100644
regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_mow_with_sync_mv.groovy
create mode 100644
regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_only_keys.groovy
create mode 100644
regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_seq_map_col.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
