This is an automated email from the ASF dual-hosted git repository.
hellostephen pushed a change to branch hello-stephen-patch-5
in repository https://gitbox.apache.org/repos/asf/doris.git
from 39617eabd1d Merge branch 'master' into hello-stephen-patch-5
add 0d2ff882e26 [Enhancement](Cloud) Check auth when alter vault (#51747)
add 085d6311fb1 [fix](nereids) fix scalar subquery output nullable (#51928)
add 297315657c6 [fix](planner)fix routine load meta data failed (#52473)
add b67f6f46fbf [improve](statistics)Specify column name when insert into
stat table. (#52441)
add 49b830198bd [fix](doris compose) be disable java support (#52412)
add 1bfad89c3c8 [Feature](function) support like with escape clause
(#52146)
add 651fe776786 [fix](nereids) fix tanh cosntant folding (#52100)
add 0882f85e9fd [feature](function) add a variant of time arithmetic
(#52375)
add 5d2dc5e497b [Feature](MTMV) add mv dependence system table (#50411)
add a1653f8d67c [feature](array) Support group by Array Column (#52452)
add b943f5c7f7d [Enhancement] (nereids) implement restoreCommand in
nereids (#50638)
add 03b2f1d5334 [Chore](nereids) Remove CreateRepositoryStmt (#52336)
add ab83a6ae22c [chore](cpuresource) remove cpu resource limit in be
(#52460)
add af77883e424 [bugfix](be_metrics) update scan bytes metric correctly
(#52232)
add d58e0688b88 [fix](nereids) add "Check expression limit" back (#52378)
add d83289d5e82 [feat](fs)Refactor Catalog FS Access to Use Unified
StorageProperties (#52084)
add 3427013f369 [fix](test) fix lazy_materialize_topn unstable (#52545)
add 154c185b27f [Bug](topn) variant column read in topn may coredump
(#52573)
add e90ab622d8f [chore](regression-test) remove
`variant_ratio_of_defaults_as_sparse_column` in test cases (#52413)
add 84d7cbe7fc6 [Enhancement](nereids) cancel convert TableRefInfo to
TableRef in RestoreCommand (#52564)
add 99bf5032565 [clean](planner)mv removes dependency on the old optimizer
(#51826)
add b5824396ba5 [Opt](performance) Support column like use dict to speed
up query (#52517)
add bde30532f0a [clean](planner) Remove unused code in PlanNode and delete
the implementations in its subclasses (#52442)
add 60cfd23c2e3 [Fix][wg]Fix cloud workload group test error (#52574)
add bc9b4288c77 [feture](vector) Extend the index interface to support
vector indexing (#52445)
add 721de70263f [fix](regression-test) fix broker load regression-test
(#51865)
add 24e179343d8 [opt](meta-service) Add changed value hex for set_value
API (#52050)
add 02200fce6d3 [test](mtmv) Fix regression test not stable and fail
(#52550)
add db806d2d29f [fix](be) Fix `check_storage_vault` deadlock (#52541)
add 0f8a93376dc [enhance](compaction) optimize mow base compaction
parameters (#52321)
add 8270ea90eed [fix](mow) fix potential mem leak for
DeleteBitmap::AggCache (#52596)
add 6daebd8939d [fix](ci) adjust perf and vault_p0 (#52604)
add f6071048bdd [feat](cluster-snapshot) Add Versionstamp and
encode/decode methods (#52595)
add 0a69acbbad6 [fix](hudi) fix quering hudi tables error (#52548)
add 1f5777a8c4b [fix](main) check error immediately after flight_server
init (#52616)
add 014c77e74b8 [Chore](nereids) Remove TruncateTableStmt (#52474)
add fdf9281e847 [improve](statistics)Support sample column skew info.
(#52048)
add af9526ace90 [fix](inverted index) Fix NonConcurrent case failure
(#52607)
add 67769750f96 [Fix](Variant) add implementation `update_XXXhash` for
IColumnDummy (#52610)
add 6d8df5a1868 [feat](cluster-snapshot) add cluster snapshot protobuf
definition (#52405)
add 0005780e06a Revert "[refactor](sink) refactor vtablet writer v2
sequential close … (#52566)
add 53cb35ad5c8 [fix](txn load) fix delete in txn load (#52133)
add 4280658758c [opt](cache) Reset initial capacity of all caches after
Cgroup memory limit changes (#51216)
add 46e94051590 [fix](cache) Add conf `segment_cache_enable_prune` (#52513)
add 63845e2ef59 [clean](planner) Remove unused code in subclasses of
PlanNode (#52592)
add 5629b71db8d [feature](function) support to_json function (#52104)
add 3bd6fdeedd0 [fix](cloud)Fix modify the cluster public and private
network causing the node to be temporarily offline (#52294)
add 88047ef20c1 [improve](fdb) Add peek() and exact row limitation to
FullRangeGetIterato (#52551)
add 025c55d131f [fix](regression-test) fix variant_p2 case to show load
failure (#52652)
add c73267ffc4d [Feture](function) Support Time Function (#51475)
add f0a28a00802 [clean](planner) Remove 6 DML stmts (#52597)
add 23686835f38 [chore](variant) rename object to variant (#52631)
add cae49a54972 [fix](auth)fix when authentication, the permissions of
multiple roles should be merged (#52349)
add 15b8655abf8 [fix](regression) case bug (#52682)
add 1babaa42977 [fix](inverted index) index-tool compile error (#52508)
add 0b544992ed4 [fix](test) fix nonConcurrent case failure (#52681)
add 50cdda94650 [fix](ubsan) fix ubsan error in DataTypeHLL::deserialize
(#52645)
add 696db15555e [regression-test](Variant) add escaped chars cases (#52657)
add 8561a5f8f1f [behavior change](agg) The array type returned by foreach
is always array<nullable<T>> (#52679)
add cc6c9ac8c60 [Opt](mow) Move `DeleteBitmapAggCache` to `ExecEnv`
(#52649)
add a085273f7ca [compile](arm) Add ARM_MARCH to specify the ARM
architecture instruction set (#52678)
add 5c53bfcf928 [fix](hive) use the remote name when get meta from hive
system. (#52561)
add f00c8a63b6c [fix](json) Add . after in JSON path to support correct
token parsing (#52543)
add 2618116c4f4 [chore](cloud) Move txn kv related files to meta-store/
(#52638)
add 2139439896e [chore](cloud) add document_put/get/remove methods (#52316)
add c2a3c5b3067 [fix](mow) fix potential mem leak for
DeleteBitmap::get_agg (#52718)
add a29271063c9 [Fix](arm) fix arm compile failure in clang-16 (#52734)
add 2691b6b2d07 [Fix](fe) fix redundant stdout by mistake (#52733)
add 4a393eac401 [Chore](function) remove some unused code and reduce some
template about agg function (#52658)
add ce3bbf97e7a [opt](ci) check stop grace and detected memory
leak|undefined-behavior (#52725)
add d6a3bdd60d7 [fix](nereids) fix bug when CTEConsumer is used as runtime
filter target (#51807)
add dc10c65a148 [opt](nereids)add comments for CompressedMaterialize and
NormalizeAggregate order (#52238)
add e16aca6edd4 [feat](txnkv) Improve range get options (#52730)
add 3f504174c4c [improve](statistics)Add hot values to column statistics
to string. (#52651)
add 6c3812d0e76 [fix](nereids) update shape plan in order_push_down.out
(#52590)
add 46cbe76a130 [fix](job) fix routine load task scheduler block for one
job can not find any BE (#52654)
add a598835d8b8 [fix](sink) fix sink operator tolerate failed replica
number incorrect (#52560)
add 821bcadc936 [fix](move-memtable) gracefully shutdown flush token in
TabletStream::pre_close (#52719)
add 7b525af234a [test](ubsan) try open ubsan mem alignment options (#52475)
add 3226898ea30 [opt](nereids) opt eliminate empty relation with union
(#52742)
add f6411d547b7 [clean](planner) Remove select stmt (#52643)
add 81a62cda03c [typo](nereids)remove useless code (#52569)
add 6ce5fc4b175 [fix](alter table) remove duplicate tableName field in
Index related options. (#52661)
add b66c78cbbe0 [feature](external) Support reading Hudi/Paimon/Iceberg
tables after schema changes. (#51341)
add f5ad72c112a [fix](serde)fix orc remalloc memory leak (#52676)
add b4653268258 [feat](catalog) Support reading Hive table with
MultiDelimitSerDe (#51936)
add 9a11a33136e [fix](ui) fix ui builds failed error (#52711)
add 1081085ebc3 [fix](be) fix parquet file reader not updating page index
when processing it (#52228)
add 64608924066 [fix](regression-framework) fix time type compatibility in
regression framework(#52692)
add 8661de8b3d3 [enhance](auth) remove qualifiedUser of ConnectContext
(#52653)
add f4a27b7e368 [Chore](util) remove some unused code on var_int.h (#52675)
add 3652a1dbfb8 [fix](ci) exclude case with known issue of memory leak
(#52784)
add d60c7fc8e26 [fix](ci) fix typo (#52763)
add e67e2df18ff [feature](fe) add arthas tool in fe (#52359)
add e74a5a18c7b [enhancement](cloud) Persist LRU information for file
cache (#49456)
add 4c241d88583 [opt](tvf) longer the timeout of getting file list from
backend (#52774)
add 641fe19d193 [opt](cloud) Optimize balance speed by reducing the
complexity of the rebalance algorithm (#51733)
add e98e05d2c6f [fix](be java) be hang while enable_java_support (#52818)
add 295dd0fcb26 [bugfix](memleak) missed add bufferred to releasable
buffer list (#52822)
add 4d56e4ebd06 [chore](be) remove useless errorno code (#52766)
add bc036781ff3 [fix](be-jni-env) Fix java.lang.StackOverflowError thrown
from the UncaughtExceptionHandler in thread "process reaper". (#52821)
add a9d83b83dff [refactor](sink) refactor vtablet writer v2 sequential
close to parallel close (#52639)
add a1b7c42e57f [Exec](alias) support stddev alias to std (#52819)
add ebc63eabaaa [fix](test)(jdbc) fix some external regression test cases
and jdbc bug (#52817)
add c334a01575a [fix](external) check duplicate column names for external
table schema (#52315)
add 969f5feff78 [fix](chore) fix cache release core (#52756)
add 9920e9678f7 [improve](hive row count)Log stack info when fetch hive
row count fail. (#52795)
add d4d556851da [improve](analytic) support window function execute with
incremental mode (#52138)
add 723bcbd6835 [fix](session variables) Limit query_timeout to within
LoadTimeout (#51222)
add 285b1e45df2 [Opt](cloud-mow) Do fast retry when commit compaction job
for mow tablet (#52476)
add 522cefb0b34 [chore](cloud) Add async wrap for `bthread_fork_join` with
promise-future (#52816)
add 95a01acec32 [feat](txnkv) support atomic_set_ver_key with offset
(#52671)
add 7efcf534b18 [Opt](cloud-mow) Retry to commit txn when encounter stale
calc delete bitmap response regardless of status code (#52547)
add ea6202576c7 [opt](auditlog) Use varchar(1024) for column frontend_ip
of audit log table (#52762)
add 4c6f12fb2ba [opt](nereids) optimize stats derive when using delta rows
(#52788)
add 78ff9e56489 [feat](nereids)support stats derive in RBO phase (#52385)
add 8254daed946 [fix](be) fix macos report wrong cpu cores (#52726)
add fe0fb6a55aa [fix](txnkv) avoid skip keys during reverse full range
iteration (#52800)
add cc7a1f93c4b [chore](profile) Modify profile structure (#48184)
add c10bbe95103 [Enhancement] (nereids) implement mysqlLoadCommand in
nereids (#49109)
add 581872aba8d [fix](test) fix audit_log regression test (#52587)
add 29421edd7f2 [fix](nereids)fix multi_leading regression test case
(#51165)
add d4290b684c1 [fix](nereids)scalar subquery should not show error
message when there are multiple agg functions in top-level agg node (#52667)
add a241e668f79 [Fix](UBSan) fix mem alignment in rapidjson ralated code
(#52809)
add c3608472624 [fix](Nereids) not process must shuffle when regulate can
not be banned agg (#52827)
add bcb06ac3b55 [chore](build) suppress BE CMake warning about unused
variable (#52891)
add 390e18283e7 [Fix](ub) Fix undefined behaviour on visiting vector
(#52901)
add 64c7f80ac64 [chore] Add GCC 15 and Clang 20 Support (#52835)
add 527a714a4b7 [fix](job) remove can not transform RUNNING to
NEED_SCHEDULE limit (#52887)
add 7dea4c62764 branch-3.1: [opt](ci) add performance check as required
(#52904)
add da9c1cfba97 [fix](load) Convert RowInBlock* to shared_ptr to fix
potential memory leaks in MemTable (#52902)
add d2e67fc07b3 [improve](mow) refactor mow update lock for schema change
to reduce txn conflict (#51301)
add bcdc2873d7b [opt](create table) Fixed table creation becomes slower as
the number of tablets increases (#52688)
add f38e98b3e52 [feat](nereids)support count/sum(distinct A) for window
(#51821)
add 8d0830793c3 [refine](function) function catch throw exception (#52511)
add 34b8e7d149b [opt](group_concat) allow args be types other than string
(#52805)
add 355b4b94fea [fix](audit) fix audit log test (#52913)
add f2501e03802 [feat](json) new version of json_array function (#52724)
add f3ef6a54662 [fix](hint) fix leading when use dphyper (#48756)
add 773bff4b3fa [enhance](auth)Remove restrictions on user creation and
other operations when enabling ranger/LDAP (#50139)
add 37104125d1f [test](asan/ubsan) try open strict-aliasing (#52851)
add d982d372725 [Enhancement] (nereids)implement
unsupportedStartTransactionCommand in nereids (#52834)
add b9d7aff92b8 [fix](nereids)agg funs case insensitive (#50444)
add 6cff01ca806 [feat](iceberg) implement hdfs fileio for iceberg (#51778)
add d1983dd153f [fix](paimon) fix CacheException msg in loadSnapshot
(#52881)
add d7ae50363bc [Feature](function) support function cot/sec/cosec (#52872)
add 373ef9bfeb0 [feat](cloud) Add versioned keys definition (#52752)
add 37b26095bdb [fix](be-jni-env) Fix missing equal sign of
'-Djdk.lang.processReaperUseDefaultStackSize'. (#52828)
add e26ace3222e [feat](param-refactor)Refactor HMS Integration Parameters
(#52363)
add d2140a981ef [fix](coordinator) fix cte with local shuffle throw
exception (#52870)
add 819e5a0b8a9 [chore](typo) fix typo error (#52825)
add e3b5bf48aa8 [Fix](mow) Fix `DeleteBitmap`'s assignment operator and
constructor (#52582)
add 1076130d882 [Test](nereids) Add ut for MysqlLoadCommand in nereids
(#52905)
add 7dc9c0dd074 [opt](cloud) add Sanitizer options (#52883)
add cad09ebf811 [Chore](status) show inner error msg when
write_file_cache_version failed (#52953)
add e2a98744ff9 [Chore](function) keep invalid escape as literal mean in
function 'like' (#52669)
add 145d30d912d [fix](regression-suites) fix compare result bug (#52970)
add d27e77edda4 [fix](nereids) fix show temp table status in
ShowTableStatusCommand (#52926)
add 5d8b4dfcd36 [ci](nonConcurrent) suppress leaks about index (#52959)
add bf4dcd7cfaf [ci](nonConcurrent) set required on master (#52987)
add d7fa32f4696 [Chore](build) Adapt ldb toolchain 0.25 (#52820)
add 8e40b3a1dd8 [optimize](util) Faster bit_pack (#52829)
add b7efbf155fb [clean](planner) Remove query stmt (#52790)
add eaea3cc5754 [fix](json) incorrect result for json path with wildcard
(#52161)
add 74d34505392 [clean](mv) remove rbo mv rewrite rule (#52736)
add 4b8c3b62970 [Opt](command) Speed up UNSET GLOBAL VARIABLE ALL (#53001)
add fa3b5dd8135 [fix](audit) fix invalid audit log column and line
separator (#52968)
add b3b9de1f77b [ci](cloud_p0) pipeline fail if stop grace fail (#52886)
add 0ad047de157 Merge branch 'master' into hello-stephen-patch-5
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 4 +-
be/CMakeLists.txt | 9 +-
be/benchmark/benchmark_bit_pack.cpp | 103 +
be/benchmark/benchmark_main.cpp | 4 +-
be/src/cloud/cloud_base_compaction.cpp | 6 +-
be/src/cloud/cloud_meta_mgr.cpp | 32 +-
be/src/cloud/cloud_meta_mgr.h | 9 +
be/src/cloud/cloud_storage_engine.cpp | 32 +-
be/src/cloud/cloud_storage_engine.h | 4 +-
be/src/cloud/config.cpp | 2 +-
be/src/cloud/pb_convert.cpp | 13 +
be/src/common/compiler_util.h | 6 +
be/src/common/config.cpp | 15 +-
be/src/common/config.h | 15 +-
be/src/common/status.h | 2 +-
be/src/exec/rowid_fetcher.cpp | 24 +-
be/src/exec/schema_scanner.cpp | 3 +
.../schema_view_dependency_scanner.cpp | 142 +
.../schema_view_dependency_scanner.h} | 54 +-
be/src/exec/table_connector.cpp | 9 +-
be/src/exec/tablet_info.cpp | 6 +
be/src/exec/tablet_info.h | 2 +
be/src/exprs/json_functions.cpp | 9 +-
be/src/glibc-compatibility/glibc-compatibility.c | 9 +
be/src/gutil/endian.h | 62 -
be/src/http/action/shrink_mem_action.cpp | 2 +
be/src/index-tools/index_tool.cpp | 38 +-
be/src/io/cache/block_file_cache.cpp | 241 +-
be/src/io/cache/block_file_cache.h | 130 +-
be/src/io/cache/cache_lru_dumper.cpp | 465 ++++
be/src/io/cache/cache_lru_dumper.h | 83 +
be/src/io/cache/file_block.cpp | 8 +-
be/src/io/cache/file_cache_common.cpp | 57 +
be/src/io/cache/file_cache_common.h | 99 +
be/src/io/cache/fs_file_cache_storage.cpp | 16 +-
be/src/io/cache/lru_queue_recorder.cpp | 132 +
be/src/io/cache/lru_queue_recorder.h | 83 +
be/src/olap/accept_null_predicate.h | 2 +-
be/src/olap/base_compaction.cpp | 6 +-
be/src/olap/bitmap_filter_predicate.h | 2 +
be/src/olap/bloom_filter_predicate.h | 2 +
be/src/olap/column_predicate.h | 12 +-
be/src/olap/compaction.cpp | 24 +-
be/src/olap/comparison_predicate.h | 18 +-
be/src/olap/in_list_predicate.h | 14 +-
be/src/olap/like_column_predicate.cpp | 21 +-
be/src/olap/like_column_predicate.h | 63 +-
be/src/olap/lru_cache.cpp | 4 +
be/src/olap/memtable.cpp | 62 +-
be/src/olap/memtable.h | 6 +-
be/src/olap/metadata_adder.h | 6 +-
be/src/olap/null_predicate.cpp | 2 +-
be/src/olap/null_predicate.h | 2 +-
be/src/olap/olap_common.h | 2 +-
be/src/olap/push_handler.cpp | 8 +-
be/src/olap/rowset/beta_rowset.cpp | 20 +-
be/src/olap/rowset/beta_rowset_writer.cpp | 12 +-
be/src/olap/rowset/beta_rowset_writer.h | 13 +-
be/src/olap/rowset/rowset_meta.cpp | 2 +-
be/src/olap/rowset/rowset_writer.h | 8 +-
be/src/olap/rowset/segcompaction.cpp | 4 +-
be/src/olap/rowset/segcompaction.h | 8 +-
be/src/olap/rowset/segment_creator.cpp | 18 +-
be/src/olap/rowset/segment_creator.h | 8 +-
be/src/olap/rowset/segment_v2/column_reader.cpp | 34 +-
be/src/olap/rowset/segment_v2/column_reader.h | 27 +-
be/src/olap/rowset/segment_v2/column_writer.cpp | 4 +-
be/src/olap/rowset/segment_v2/column_writer.h | 2 +-
.../rowset/segment_v2/hierarchical_data_reader.h | 2 +-
...index_file_reader.cpp => index_file_reader.cpp} | 22 +-
...ted_index_file_reader.h => index_file_reader.h} | 12 +-
.../olap/rowset/segment_v2/index_file_writer.cpp | 233 ++
be/src/olap/rowset/segment_v2/index_file_writer.h | 110 +
be/src/olap/rowset/segment_v2/index_iterator.h | 57 +
be/src/olap/rowset/segment_v2/index_reader.h | 58 +
.../rowset/segment_v2/index_storage_format.cpp | 123 +
...d_index_compaction.h => index_storage_format.h} | 51 +-
.../rowset/segment_v2/index_storage_format_v1.cpp | 192 ++
.../rowset/segment_v2/index_storage_format_v1.h | 47 +
.../rowset/segment_v2/index_storage_format_v2.cpp | 247 ++
.../rowset/segment_v2/index_storage_format_v2.h | 58 +
.../segment_v2/inverted_index/util/term_iterator.h | 4 +-
.../inverted_index/util/term_position_iterator.h | 6 +-
.../segment_v2/inverted_index_compaction.cpp | 2 +-
.../rowset/segment_v2/inverted_index_compaction.h | 4 +-
.../segment_v2/inverted_index_file_writer.cpp | 676 -----
.../rowset/segment_v2/inverted_index_file_writer.h | 181 --
.../rowset/segment_v2/inverted_index_iterator.cpp | 109 +
.../rowset/segment_v2/inverted_index_iterator.h | 58 +
.../rowset/segment_v2/inverted_index_reader.cpp | 125 +-
.../olap/rowset/segment_v2/inverted_index_reader.h | 90 +-
.../rowset/segment_v2/inverted_index_writer.cpp | 8 +-
.../olap/rowset/segment_v2/inverted_index_writer.h | 5 +-
be/src/olap/rowset/segment_v2/page_io.cpp | 2 +
be/src/olap/rowset/segment_v2/segment.cpp | 31 +-
be/src/olap/rowset/segment_v2/segment.h | 16 +-
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 50 +-
be/src/olap/rowset/segment_v2/segment_iterator.h | 18 +-
be/src/olap/rowset/segment_v2/segment_writer.cpp | 10 +-
be/src/olap/rowset/segment_v2/segment_writer.h | 13 +-
.../rowset/segment_v2/vertical_segment_writer.cpp | 10 +-
.../rowset/segment_v2/vertical_segment_writer.h | 14 +-
be/src/olap/rowset/vertical_beta_rowset_writer.cpp | 9 +-
be/src/olap/segment_loader.h | 3 +-
be/src/olap/shared_predicate.h | 2 +-
be/src/olap/tablet_meta.cpp | 89 +-
be/src/olap/tablet_meta.h | 49 +-
be/src/olap/tablet_meta_manager.cpp | 5 +-
be/src/olap/task/index_builder.cpp | 65 +-
be/src/olap/task/index_builder.h | 11 +-
be/src/pipeline/exec/aggregation_sink_operator.cpp | 31 +-
.../pipeline/exec/aggregation_source_operator.cpp | 28 +-
be/src/pipeline/exec/analytic_sink_operator.cpp | 74 +-
be/src/pipeline/exec/analytic_sink_operator.h | 5 +-
be/src/pipeline/exec/analytic_source_operator.cpp | 4 +-
be/src/pipeline/exec/cache_source_operator.cpp | 6 +-
be/src/pipeline/exec/datagen_operator.cpp | 4 +-
.../distinct_streaming_aggregation_operator.cpp | 13 +-
be/src/pipeline/exec/es_scan_operator.cpp | 6 +-
be/src/pipeline/exec/exchange_sink_buffer.cpp | 4 +-
be/src/pipeline/exec/exchange_sink_buffer.h | 2 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 66 +-
be/src/pipeline/exec/exchange_sink_operator.h | 8 +-
be/src/pipeline/exec/exchange_source_operator.cpp | 14 +-
be/src/pipeline/exec/file_scan_operator.cpp | 2 +-
.../exec/group_commit_block_sink_operator.cpp | 8 +-
be/src/pipeline/exec/hashjoin_build_sink.cpp | 24 +-
be/src/pipeline/exec/hashjoin_probe_operator.cpp | 17 +-
be/src/pipeline/exec/jdbc_scan_operator.cpp | 7 +-
be/src/pipeline/exec/join_build_sink_operator.cpp | 5 +-
be/src/pipeline/exec/join_probe_operator.cpp | 11 +-
.../exec/local_merge_sort_source_operator.cpp | 2 +-
.../exec/materialization_source_operator.h | 4 +-
.../pipeline/exec/memory_scratch_sink_operator.cpp | 7 +-
be/src/pipeline/exec/meta_scan_operator.cpp | 3 +-
.../pipeline/exec/multi_cast_data_stream_sink.cpp | 15 +-
be/src/pipeline/exec/multi_cast_data_stream_sink.h | 6 +-
.../exec/multi_cast_data_stream_source.cpp | 18 +-
.../pipeline/exec/multi_cast_data_stream_source.h | 4 +-
be/src/pipeline/exec/multi_cast_data_streamer.cpp | 13 +-
be/src/pipeline/exec/multi_cast_data_streamer.h | 11 +-
.../exec/nested_loop_join_build_operator.cpp | 3 +-
.../exec/nested_loop_join_probe_operator.cpp | 10 +-
be/src/pipeline/exec/olap_scan_operator.cpp | 22 +-
be/src/pipeline/exec/olap_scan_operator.h | 8 +-
be/src/pipeline/exec/operator.cpp | 96 +-
be/src/pipeline/exec/operator.h | 148 +-
.../pipeline/exec/partition_sort_sink_operator.cpp | 34 +-
.../exec/partition_sort_source_operator.cpp | 4 +-
.../exec/partitioned_aggregation_sink_operator.cpp | 20 +-
.../exec/partitioned_aggregation_sink_operator.h | 2 +-
.../partitioned_aggregation_source_operator.cpp | 10 +-
.../exec/partitioned_hash_join_probe_operator.cpp | 125 +-
.../exec/partitioned_hash_join_probe_operator.h | 10 +-
.../exec/partitioned_hash_join_sink_operator.cpp | 29 +-
be/src/pipeline/exec/repeat_operator.cpp | 6 +-
be/src/pipeline/exec/result_sink_operator.cpp | 12 +-
be/src/pipeline/exec/scan_operator.cpp | 26 +-
be/src/pipeline/exec/schema_scan_operator.cpp | 2 +-
be/src/pipeline/exec/set_probe_sink_operator.cpp | 4 +-
be/src/pipeline/exec/set_sink_operator.cpp | 7 +-
be/src/pipeline/exec/set_source_operator.cpp | 4 +-
be/src/pipeline/exec/sort_sink_operator.cpp | 16 +-
be/src/pipeline/exec/spill_sort_sink_operator.cpp | 23 +-
.../pipeline/exec/spill_sort_source_operator.cpp | 10 +-
be/src/pipeline/exec/spill_utils.h | 52 +-
.../exec/streaming_aggregation_operator.cpp | 35 +-
be/src/pipeline/exec/table_function_operator.cpp | 6 +-
be/src/pipeline/exec/union_sink_operator.cpp | 2 +-
be/src/pipeline/exec/union_source_operator.cpp | 2 +-
.../local_exchange_sink_operator.cpp | 10 +-
.../local_exchange_source_operator.cpp | 4 +-
.../local_exchange_source_operator.h | 2 +-
be/src/pipeline/pipeline_fragment_context.cpp | 6 +-
be/src/pipeline/pipeline_task.cpp | 7 +-
be/src/runtime/descriptors.h | 2 +-
be/src/runtime/exec_env.h | 8 +
be/src/runtime/exec_env_init.cpp | 12 +
be/src/runtime/fragment_mgr.cpp | 14 -
be/src/runtime/fragment_mgr.h | 3 -
be/src/runtime/load_channel.cpp | 3 +
be/src/runtime/load_stream.cpp | 2 +
be/src/runtime/memory/cache_manager.cpp | 7 +
be/src/runtime/memory/cache_manager.h | 2 +
be/src/runtime/memory/cache_policy.h | 1 +
be/src/runtime/memory/lru_cache_policy.h | 22 +-
be/src/runtime/query_context.cpp | 12 -
be/src/runtime/query_context.h | 16 -
be/src/service/doris_main.cpp | 4 +-
be/src/service/point_query_executor.h | 7 +-
be/src/util/bit_packing.inline.h | 2 +-
be/src/util/byte_stream_split.cpp | 1 +
be/src/util/cpu_info.cpp | 6 +-
be/src/util/doris_metrics.cpp | 4 +
be/src/util/doris_metrics.h | 2 +
be/src/util/frame_of_reference_coding.cpp | 182 +-
be/src/util/frame_of_reference_coding.h | 7 +
be/src/util/hash_util.hpp | 4 +-
be/src/util/jni-util.cpp | 4 +
be/src/util/jsonb_document.cpp | 128 +
be/src/util/jsonb_document.h | 115 +-
be/src/util/jsonb_utils.h | 12 +-
be/src/util/mem_info.cpp | 8 +
be/src/util/murmur_hash3.cpp | 6 +-
be/src/util/proto_util.h | 6 +-
be/src/util/quantile_state.cpp | 13 +-
be/src/util/runtime_profile.cpp | 11 +
be/src/util/runtime_profile.h | 2 +
be/src/util/string_util.h | 15 +
.../vec/aggregate_functions/aggregate_function.h | 52 +-
.../aggregate_function_approx_count_distinct.cpp | 8 -
.../aggregate_function_approx_top_k.cpp | 1 -
.../aggregate_function_approx_top_sum.cpp | 6 +-
.../aggregate_function_array_agg.cpp | 6 +-
.../aggregate_functions/aggregate_function_avg.h | 77 +-
.../aggregate_function_binary.h | 86 +-
.../aggregate_function_collect.cpp | 18 +-
.../aggregate_function_collect.h | 24 +-
.../aggregate_function_corr.cpp | 45 +-
.../aggregate_functions/aggregate_function_corr.h | 4 +-
.../aggregate_functions/aggregate_function_count.h | 46 +
.../aggregate_function_covar.cpp | 38 +-
.../aggregate_function_foreachv2.cpp | 108 +
.../aggregate_function_group_array_intersect.cpp | 41 +-
.../aggregate_function_java_udaf.h | 11 +-
.../aggregate_function_min_max.h | 98 +
.../aggregate_functions/aggregate_function_null.h | 106 +-
.../aggregate_function_orthogonal_bitmap.cpp | 4 +-
.../aggregate_function_reader_first_last.h | 2 +-
.../aggregate_function_simple_factory.cpp | 5 +-
.../aggregate_function_simple_factory.h | 10 +-
.../aggregate_function_stddev.cpp | 1 +
.../aggregate_functions/aggregate_function_sum.h | 58 +
.../aggregate_function_uniq.cpp | 4 +
.../aggregate_functions/aggregate_function_uniq.h | 27 +-
.../aggregate_function_window.h | 14 +-
be/src/vec/aggregate_functions/factory_helpers.h | 1 -
be/src/vec/aggregate_functions/helpers.h | 27 +-
be/src/vec/columns/column.h | 2 +-
be/src/vec/columns/column_array.cpp | 152 +
be/src/vec/columns/column_array.h | 9 +-
be/src/vec/columns/column_decimal.cpp | 4 +-
be/src/vec/columns/column_dictionary.h | 2 +-
be/src/vec/columns/column_dummy.h | 15 +
be/src/vec/columns/column_nullable.h | 7 +-
be/src/vec/columns/column_set.h | 50 -
be/src/vec/columns/column_vector.h | 2 +-
be/src/vec/common/hash_table/hash_key_type.h | 5 +-
be/src/vec/common/hash_table/hash_map_context.h | 1 +
be/src/vec/common/schema_util.cpp | 2 +-
be/src/vec/core/sort_block.h | 15 +-
be/src/vec/data_types/data_type.cpp | 14 +-
be/src/vec/data_types/data_type_array.cpp | 4 +-
be/src/vec/data_types/data_type_bitmap.cpp | 16 +-
.../data_types/data_type_date_or_datetime_v2.cpp | 13 +
be/src/vec/data_types/data_type_decimal.cpp | 8 +-
.../data_types/data_type_fixed_length_object.cpp | 20 +-
be/src/vec/data_types/data_type_hll.cpp | 7 +-
be/src/vec/data_types/data_type_nullable.cpp | 8 +-
be/src/vec/data_types/data_type_number_base.cpp | 8 +-
be/src/vec/data_types/data_type_quantilestate.cpp | 18 +-
be/src/vec/data_types/data_type_string.cpp | 28 +-
be/src/vec/data_types/data_type_variant.cpp | 42 +-
be/src/vec/data_types/data_type_variant.h | 2 +-
.../vec/data_types/serde/data_type_array_serde.cpp | 23 +
.../vec/data_types/serde/data_type_array_serde.h | 3 +
.../data_types/serde/data_type_bitmap_serde.cpp | 34 +-
.../data_types/serde/data_type_date64_serde.cpp | 48 +-
.../data_types/serde/data_type_decimal_serde.cpp | 37 +
.../vec/data_types/serde/data_type_decimal_serde.h | 5 +
.../vec/data_types/serde/data_type_hll_serde.cpp | 34 +-
.../vec/data_types/serde/data_type_ipv6_serde.cpp | 47 +-
.../vec/data_types/serde/data_type_jsonb_serde.cpp | 51 +-
.../data_types/serde/data_type_nullable_serde.cpp | 14 +
.../data_types/serde/data_type_nullable_serde.h | 3 +
.../data_types/serde/data_type_number_serde.cpp | 101 +-
.../vec/data_types/serde/data_type_number_serde.h | 5 +
.../serde/data_type_quantilestate_serde.h | 34 +-
be/src/vec/data_types/serde/data_type_serde.cpp | 13 +
be/src/vec/data_types/serde/data_type_serde.h | 33 +-
.../data_types/serde/data_type_string_serde.cpp | 26 +
.../vec/data_types/serde/data_type_string_serde.h | 9 +-
.../data_types/serde/data_type_struct_serde.cpp | 29 +
.../vec/data_types/serde/data_type_struct_serde.h | 3 +
...bject_serde.cpp => data_type_variant_serde.cpp} | 56 +-
...pe_object_serde.h => data_type_variant_serde.h} | 0
be/src/vec/exec/format/orc/vorc_reader.cpp | 386 ++-
be/src/vec/exec/format/orc/vorc_reader.h | 91 +-
be/src/vec/exec/format/parquet/schema_desc.cpp | 25 +-
be/src/vec/exec/format/parquet/schema_desc.h | 11 +-
.../exec/format/parquet/vparquet_column_reader.cpp | 64 +-
.../exec/format/parquet/vparquet_column_reader.h | 22 +-
.../exec/format/parquet/vparquet_group_reader.cpp | 31 +-
.../exec/format/parquet/vparquet_group_reader.h | 9 +-
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 154 +-
be/src/vec/exec/format/parquet/vparquet_reader.h | 32 +-
be/src/vec/exec/format/table/hive_reader.cpp | 132 +
.../format/table/{hudi_reader.h => hive_reader.h} | 34 +-
be/src/vec/exec/format/table/hudi_reader.cpp | 59 +-
be/src/vec/exec/format/table/hudi_reader.h | 24 -
be/src/vec/exec/format/table/iceberg_reader.cpp | 127 +-
be/src/vec/exec/format/table/iceberg_reader.h | 11 +-
be/src/vec/exec/format/table/paimon_reader.cpp | 18 -
be/src/vec/exec/format/table/paimon_reader.h | 42 +-
.../vec/exec/format/table/table_format_reader.cpp | 687 ++++-
be/src/vec/exec/format/table/table_format_reader.h | 292 +-
.../format/table/transactional_hive_reader.cpp | 64 +-
.../exec/format/table/transactional_hive_reader.h | 2 +-
be/src/vec/exec/format/text/text_reader.cpp | 56 +
be/src/vec/exec/format/text/text_reader.h | 3 +
be/src/vec/exec/scan/file_scanner.cpp | 173 +-
be/src/vec/exec/scan/file_scanner.h | 8 +-
be/src/vec/exec/scan/olap_scanner.cpp | 55 +-
be/src/vec/exec/scan/olap_scanner.h | 4 +-
be/src/vec/exec/scan/scanner.cpp | 11 -
be/src/vec/exec/scan/scanner.h | 4 +
be/src/vec/exec/scan/scanner_context.cpp | 5 -
be/src/vec/exec/scan/scanner_context.h | 2 -
be/src/vec/exec/scan/scanner_scheduler.cpp | 84 +-
be/src/vec/exec/scan/scanner_scheduler.h | 6 -
be/src/vec/exec/vjdbc_connector.h | 4 +-
be/src/vec/exprs/vdirect_in_predicate.h | 2 +-
be/src/vec/exprs/vectorized_agg_fn.cpp | 6 +-
be/src/vec/exprs/vectorized_fn_call.cpp | 2 +-
be/src/vec/exprs/vectorized_fn_call.h | 2 +-
be/src/vec/exprs/vexpr.cpp | 2 +-
be/src/vec/exprs/vexpr.h | 2 +-
be/src/vec/exprs/vexpr_context.h | 19 +-
be/src/vec/exprs/vruntimefilter_wrapper.cpp | 2 +-
be/src/vec/functions/array/function_array_index.h | 23 +-
.../vec/functions/array/function_arrays_overlap.h | 20 +-
be/src/vec/functions/date_time_transforms.h | 13 +
be/src/vec/functions/function.h | 21 +-
be/src/vec/functions/function_cast.h | 7 +-
.../function_date_or_datetime_computation.cpp | 1 +
.../function_date_or_datetime_computation.h | 31 +
.../vec/functions/function_datetime_floor_ceil.cpp | 13 +
be/src/vec/functions/function_ip.h | 38 +-
be/src/vec/functions/function_json.cpp | 150 +-
be/src/vec/functions/function_jsonb.cpp | 223 +-
be/src/vec/functions/function_multi_match.cpp | 16 +-
be/src/vec/functions/function_multi_match.h | 2 +-
be/src/vec/functions/function_rpc.cpp | 7 -
be/src/vec/functions/function_rpc.h | 20 +-
be/src/vec/functions/function_string.h | 1 -
be/src/vec/functions/function_to_json.cpp | 57 +
be/src/vec/functions/function_tokenize.cpp | 2 +-
be/src/vec/functions/functions_comparison.h | 22 +-
be/src/vec/functions/in.h | 18 +-
be/src/vec/functions/is_not_null.h | 8 +-
be/src/vec/functions/is_null.h | 8 +-
be/src/vec/functions/like.cpp | 96 +-
be/src/vec/functions/like.h | 34 +-
be/src/vec/functions/match.cpp | 31 +-
be/src/vec/functions/match.h | 3 +-
be/src/vec/functions/math.cpp | 27 +
be/src/vec/functions/simple_function_factory.h | 9 +
be/src/vec/io/var_int.h | 118 -
be/src/vec/json/parse2column.cpp | 18 +-
be/src/vec/runtime/vdatetime_value.cpp | 88 +-
be/src/vec/runtime/vdatetime_value.h | 82 +-
be/src/vec/sink/load_stream_stub.cpp | 6 +-
be/src/vec/sink/vrow_distribution.cpp | 2 +-
be/src/vec/sink/writer/async_result_writer.cpp | 22 +-
be/src/vec/sink/writer/async_result_writer.h | 8 +-
.../sink/writer/iceberg/viceberg_table_writer.cpp | 24 +-
be/src/vec/sink/writer/vhive_partition_writer.cpp | 2 +-
be/src/vec/sink/writer/vhive_table_writer.cpp | 32 +-
be/src/vec/sink/writer/vjdbc_table_writer.h | 4 +-
be/src/vec/sink/writer/vtablet_writer.cpp | 41 +-
be/src/vec/sink/writer/vtablet_writer.h | 7 +
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 67 +-
be/src/vec/sink/writer/vtablet_writer_v2.h | 10 +-
be/src/vec/spill/spill_reader.h | 18 +-
be/src/vec/spill/spill_stream.cpp | 13 +-
be/src/vec/spill/spill_stream.h | 4 +-
be/src/vec/spill/spill_stream_manager.cpp | 5 +-
be/src/vec/spill/spill_stream_manager.h | 2 +-
be/src/vec/spill/spill_writer.h | 22 +-
be/test/cloud/cloud_meta_mgr_test.cpp | 89 +
be/test/io/cache/block_file_cache_test.cpp | 234 +-
be/test/io/cache/block_file_cache_test_common.h | 134 +
.../io/cache/block_file_cache_test_lru_dump.cpp | 404 +++
be/test/io/cache/cache_lru_dumper_test.cpp | 149 +
be/test/io/cache/lru_queue_test.cpp | 117 +
be/test/olap/lru_cache_test.cpp | 57 +
.../compaction/util/index_compaction_utils.cpp | 53 +-
.../inverted_index/empty_index_file_test.cpp | 4 +-
.../query/phrase_edge_query_test.cpp | 12 +-
.../query/phrase_prefix_query_test.cpp | 12 +-
.../inverted_index/query/phrase_query_test.cpp | 12 +-
.../segment_v2/inverted_index_array_test.cpp | 46 +-
.../inverted_index_compound_reader_test.cpp | 14 +-
.../segment_v2/inverted_index_file_reader_test.cpp | 61 +-
.../segment_v2/inverted_index_file_writer_test.cpp | 488 ++--
.../segment_v2/inverted_index_reader_test.cpp | 253 +-
.../segment_v2/inverted_index_writer_test.cpp | 78 +-
be/test/olap/storage_resource_test.cpp | 24 +-
.../exec/multi_cast_data_streamer_test.cpp | 92 +-
.../partitioned_aggregation_sink_operator_test.cpp | 18 +-
...artitioned_aggregation_source_operator_test.cpp | 18 +-
.../partitioned_aggregation_test_helper.cpp | 10 +-
.../operator/partitioned_aggregation_test_helper.h | 16 +-
.../partitioned_hash_join_probe_operator_test.cpp | 63 +-
.../partitioned_hash_join_sink_operator_test.cpp | 12 +-
.../operator/partitioned_hash_join_test_helper.cpp | 10 +-
.../operator/partitioned_hash_join_test_helper.h | 69 +-
.../operator/spill_sort_sink_operator_test.cpp | 10 +-
.../operator/spill_sort_source_operator_test.cpp | 33 +-
.../operator/spillable_operator_test_helper.cpp | 34 +-
.../operator/spillable_operator_test_helper.h | 5 +-
be/test/testutil/run_all_tests.cpp | 4 +
be/test/util/frame_of_reference_coding_test.cpp | 56 +-
be/test/util/profile_spec_test.cpp | 180 ++
be/test/util/runtime_profile_test.cpp | 30 +
be/test/vec/columns/column_array_test.cpp | 10 +-
...umn_object_test.cpp => column_variant_test.cpp} | 72 +-
be/test/vec/columns/common_column_test.h | 2 +-
be/test/vec/common/string_utils_test.cpp | 12 +
.../serde/data_type_write_to_jsonb_test.cpp | 168 ++
be/test/vec/exec/exchange_sink_test.h | 2 +-
.../format/paimon/paimon_schema_change_test.cpp | 149 -
.../vec/exec/format/parquet/parquet_read_lines.cpp | 6 +-
.../exec/format/parquet/parquet_reader_test.cpp | 97 +-
.../table/table_schema_change_helper_test.cpp | 1182 +++++---
.../format/text/hive_text_field_splitter_test.cpp | 97 +
be/test/vec/exec/orc/orc_read_lines.cpp | 6 +-
be/test/vec/exec/orc/orc_reader_fill_data_test.cpp | 30 +-
.../vec/exec/orc/orc_reader_init_column_test.cpp | 140 +-
be/test/vec/exec/orc_reader_test.cpp | 4 +-
be/test/vec/exec/sort/heap_sorter_test.cpp | 4 +-
be/test/vec/exec/sort/sort_test.cpp | 4 +-
.../exprs/vexpr_evalute_inverted_index_test.cpp | 2 +-
be/test/vec/function/function_is_null_test.cpp | 8 +-
be/test/vec/function/function_json_test.cpp | 16 +-
be/test/vec/function/function_jsonb_test.cpp | 169 +-
be/test/vec/function/function_like_test.cpp | 19 +-
be/test/vec/function/function_math_test.cpp | 31 +
be/test/vec/function/function_multi_match_test.cpp | 2 +-
.../vec/function/function_throw_exception_test.cpp | 64 +
be/test/vec/function/function_time_test.cpp | 49 +-
be/test/vec/jsonb/jsonb_document_test.cpp | 2 +-
be/test/vec/sink/vtablet_writer_v2_test.cpp | 96 +-
bin/start_be.sh | 3 +-
build.sh | 15 +
cloud/CMakeLists.txt | 5 +
.../{lsan_suppression.conf => asan_suppr.conf} | 3 -
.../{lsan_suppression.conf => lsan_suppr.conf} | 1 +
.../{lsan_suppression.conf => ubsan_suppr.conf} | 3 -
cloud/script/run_all_tests.sh | 5 +-
cloud/script/start.sh | 10 +
cloud/src/common/config.h | 7 +-
cloud/src/common/encryption_util.cpp | 6 +-
cloud/src/common/metric.cpp | 4 +-
cloud/src/common/metric.h | 2 +-
cloud/src/common/util.cpp | 141 +-
cloud/src/common/util.h | 68 +-
cloud/src/main.cpp | 4 +-
cloud/src/meta-service/CMakeLists.txt | 5 +-
cloud/src/meta-service/http_encode_key.cpp | 47 +-
cloud/src/meta-service/injection_point_http.cpp | 6 +-
cloud/src/meta-service/meta_server.cpp | 6 +-
cloud/src/meta-service/meta_server.h | 2 +-
cloud/src/meta-service/meta_service.cpp | 173 +-
cloud/src/meta-service/meta_service.h | 57 +-
cloud/src/meta-service/meta_service_helper.h | 7 +-
cloud/src/meta-service/meta_service_http.cpp | 6 +-
cloud/src/meta-service/meta_service_job.cpp | 190 +-
cloud/src/meta-service/meta_service_partition.cpp | 4 +-
cloud/src/meta-service/meta_service_resource.cpp | 6 +-
cloud/src/meta-service/meta_service_schema.cpp | 7 +-
cloud/src/meta-service/meta_service_snapshot.cpp | 64 +
.../src/meta-service/meta_service_tablet_stats.cpp | 6 +-
cloud/src/meta-service/meta_service_txn.cpp | 6 +-
cloud/src/meta-service/txn_lazy_committer.cpp | 2 +-
cloud/src/meta-service/txn_lazy_committer.h | 2 +-
cloud/src/meta-store/CMakeLists.txt | 14 +
cloud/src/meta-store/blob_message.cpp | 161 ++
.../{common/util.h => meta-store/blob_message.h} | 51 +-
cloud/src/{meta-service => meta-store}/codec.cpp | 16 +
cloud/src/{meta-service => meta-store}/codec.h | 28 +-
cloud/src/meta-store/document_message.cpp | 467 ++++
cloud/src/meta-store/document_message.h | 75 +
cloud/src/{meta-service => meta-store}/keys.cpp | 308 ++-
cloud/src/{meta-service => meta-store}/keys.h | 256 +-
.../{meta-service => meta-store}/mem_txn_kv.cpp | 289 +-
.../src/{meta-service => meta-store}/mem_txn_kv.h | 82 +-
cloud/src/{meta-service => meta-store}/txn_kv.cpp | 183 +-
cloud/src/{meta-service => meta-store}/txn_kv.h | 200 +-
.../{meta-service => meta-store}/txn_kv_error.h | 3 +
cloud/src/meta-store/versionstamp.h | 123 +
cloud/src/recycler/checker.cpp | 40 +-
cloud/src/recycler/checker.h | 2 +-
cloud/src/recycler/meta_checker.cpp | 4 +-
cloud/src/recycler/recycler.cpp | 24 +-
cloud/src/recycler/recycler_service.cpp | 4 +-
cloud/src/recycler/recycler_service.h | 2 +-
cloud/src/recycler/util.cpp | 6 +-
cloud/src/resource-manager/resource_manager.cpp | 4 +-
cloud/src/resource-manager/resource_manager.h | 4 +-
cloud/test/CMakeLists.txt | 13 +-
cloud/test/codec_test.cpp | 2 +-
cloud/test/document_message_test.cpp | 424 +++
cloud/test/doris_txn_test.cpp | 2 +-
cloud/test/encryption_test.cpp | 8 +-
cloud/test/fdb_injection_test.cpp | 2 +-
cloud/test/http_encode_key_test.cpp | 11 +-
cloud/test/keys_test.cpp | 1151 +++++++-
cloud/test/mem_txn_kv_test.cpp | 406 ++-
cloud/test/meta_server_test.cpp | 8 +-
cloud/test/meta_service_http_test.cpp | 11 +-
cloud/test/meta_service_job_test.cpp | 262 +-
cloud/test/meta_service_tablet_stats_test.cpp | 4 +-
cloud/test/meta_service_test.cpp | 147 +-
cloud/test/metric_test.cpp | 6 +-
cloud/test/mock_resource_manager.h | 4 +-
cloud/test/rate_limiter_test.cpp | 6 +-
cloud/test/recycler_test.cpp | 54 +-
cloud/test/resource_test.cpp | 6 +-
cloud/test/rpc_kv_bvar_test.cpp | 8 +-
cloud/test/schema_kv_test.cpp | 6 +-
cloud/test/txn_kv_test.cpp | 628 ++++-
cloud/test/txn_lazy_commit_test.cpp | 6 +-
cloud/test/versionstamp_test.cpp | 102 +
conf/lsan_suppr.conf | 8 +-
conf/ubsan_ignorelist.txt | 15 +
.../lsan_suppression.conf => conf/ubsan_suppr.conf | 4 +-
dist/LICENSE-dist.txt | 2 +
docker/runtime/doris-compose/cluster.py | 3 +
.../multi_delimit_serde/create_table.hql | 78 +
...-72d4d52a-eca9-4542-a2af-cc17499731e6-0.parquet | Bin 0 -> 504 bytes
...manifest-5cae1365-d123-4172-9a89-4fbc02bee658-0 | Bin 0 -> 1942 bytes
...est-list-391058a9-952c-4aa9-892f-df3334e4109b-0 | Bin 0 -> 884 bytes
...est-list-391058a9-952c-4aa9-892f-df3334e4109b-1 | Bin 0 -> 989 bytes
.../db1.db/dup_columns_table/schema/schema-0 | 19 +
.../snapshot/EARLIEST | 0
.../snapshot/LATEST | 0
.../db1.db/dup_columns_table/snapshot/snapshot-1 | 19 +
.../parquet/small_2rowgroup.parquet | Bin 0 -> 13059 bytes
.../docker-compose/iceberg/entrypoint.sh.tpl | 2 +-
.../docker-compose/iceberg/iceberg.yaml.tpl | 2 -
.../create_preinstalled_scripts/iceberg/run01.sql | 2 +-
.../create_preinstalled_scripts/iceberg/run02.sql | 1 +
.../create_preinstalled_scripts/iceberg/run03.sql | 1 +
.../create_preinstalled_scripts/iceberg/run04.sql | 2 +-
.../create_preinstalled_scripts/iceberg/run06.sql | 1 +
.../create_preinstalled_scripts/iceberg/run07.sql | 2 +-
.../create_preinstalled_scripts/iceberg/run08.sql | 2 +-
.../create_preinstalled_scripts/iceberg/run09.sql | 1 +
.../create_preinstalled_scripts/iceberg/run10.sql | 2 +-
.../create_preinstalled_scripts/iceberg/run16.sql | 421 +++
.../create_preinstalled_scripts/iceberg/run17.sql | 421 +++
.../create_preinstalled_scripts/paimon/run01.sql | 13 +-
.../create_preinstalled_scripts/paimon/run05.sql | 406 +++
fe/check/checkstyle/suppressions.xml | 3 +
.../main/java/org/apache/doris/catalog/Type.java | 4 +
.../authentication/AuthenticationConfig.java | 14 +-
.../KerberosAuthenticationConfig.java | 13 +
.../authentication/PreExecutionAuthenticator.java | 4 +
fe/fe-core/pom.xml | 6 +-
.../antlr4/org/apache/doris/nereids/DorisLexer.g4 | 1 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 22 +-
fe/fe-core/src/main/cup/sql_parser.cup | 592 +---
.../main/java/org/apache/doris/alter/Alter.java | 8 +-
.../java/org/apache/doris/alter/RollupJobV2.java | 43 +-
.../org/apache/doris/analysis/AddColumnClause.java | 4 +
.../org/apache/doris/analysis/AggregateInfo.java | 2 +-
.../org/apache/doris/analysis/AlterViewStmt.java | 27 +-
.../java/org/apache/doris/analysis/Analyzer.java | 1154 +-------
.../org/apache/doris/analysis/ArithmeticExpr.java | 79 -
.../org/apache/doris/analysis/BaseViewStmt.java | 9 +-
.../org/apache/doris/analysis/BinaryPredicate.java | 62 -
.../doris/analysis/CreateMaterializedViewStmt.java | 502 ----
.../doris/analysis/CreateRepositoryStmt.java | 101 -
.../doris/analysis/CreateRoutineLoadStmt.java | 1 -
.../doris/analysis/CreateTableAsSelectStmt.java | 82 -
.../org/apache/doris/analysis/CreateTableStmt.java | 550 ----
.../org/apache/doris/analysis/CreateViewStmt.java | 4 +-
.../org/apache/doris/analysis/DataDescription.java | 2 +-
.../java/org/apache/doris/analysis/DeleteStmt.java | 473 ----
.../org/apache/doris/analysis/DropUserStmt.java | 7 -
.../main/java/org/apache/doris/analysis/Expr.java | 47 -
.../java/org/apache/doris/analysis/FromClause.java | 280 --
.../apache/doris/analysis/FunctionCallExpr.java | 6 +-
.../org/apache/doris/analysis/GroupByClause.java | 2 +-
.../org/apache/doris/analysis/InPredicate.java | 74 -
.../org/apache/doris/analysis/InlineViewRef.java | 540 ----
.../doris/analysis/InsertOverwriteTableStmt.java | 116 -
.../java/org/apache/doris/analysis/InsertStmt.java | 341 ---
.../org/apache/doris/analysis/LateralViewRef.java | 60 +-
.../org/apache/doris/analysis/LimitElement.java | 3 -
.../org/apache/doris/analysis/LiteralExpr.java | 6 -
.../apache/doris/analysis/NativeInsertStmt.java | 1430 ----------
.../java/org/apache/doris/analysis/QueryStmt.java | 873 ------
.../org/apache/doris/analysis/SchemaTableType.java | 10 +-
.../java/org/apache/doris/analysis/SelectList.java | 151 -
.../org/apache/doris/analysis/SelectListItem.java | 163 --
.../java/org/apache/doris/analysis/SelectStmt.java | 2891 --------------------
.../java/org/apache/doris/analysis/Separator.java | 44 +
.../apache/doris/analysis/SetOperationStmt.java | 992 -------
.../apache/doris/analysis/SetUserDefinedVar.java | 43 -
.../doris/analysis/ShowCacheHotSpotStmt.java | 192 --
.../apache/doris/analysis/ShowColumnStatsStmt.java | 2 +
.../org/apache/doris/analysis/ShowColumnStmt.java | 186 --
.../java/org/apache/doris/analysis/ShowStmt.java | 5 -
.../java/org/apache/doris/analysis/SlotRef.java | 41 -
.../org/apache/doris/analysis/StatementBase.java | 69 -
.../org/apache/doris/analysis/StmtRewriter.java | 1542 -----------
.../java/org/apache/doris/analysis/Subquery.java | 128 +-
.../java/org/apache/doris/analysis/TableRef.java | 16 -
.../apache/doris/analysis/TruncateTableStmt.java | 105 -
.../java/org/apache/doris/analysis/UpdateStmt.java | 259 --
.../java/org/apache/doris/analysis/WithClause.java | 171 --
.../org/apache/doris/backup/BackupHandler.java | 228 +-
.../org/apache/doris/backup/BackupJobInfo.java | 70 +
.../doris/catalog/BuiltinAggregateFunctions.java | 16 +-
.../doris/catalog/BuiltinScalarFunctions.java | 17 +-
.../main/java/org/apache/doris/catalog/Column.java | 1 +
.../java/org/apache/doris/catalog/Database.java | 1 +
.../main/java/org/apache/doris/catalog/Env.java | 48 +-
.../java/org/apache/doris/catalog/Function.java | 5 +-
.../java/org/apache/doris/catalog/FunctionSet.java | 8 +
.../org/apache/doris/catalog/InternalSchema.java | 4 +-
.../doris/catalog/InternalSchemaInitializer.java | 320 ++-
.../java/org/apache/doris/catalog/JdbcTable.java | 16 +-
.../doris/catalog/MaterializedIndexMeta.java | 69 +-
.../java/org/apache/doris/catalog/OlapTable.java | 6 +-
.../org/apache/doris/catalog/RefreshManager.java | 8 +-
.../java/org/apache/doris/catalog/SchemaTable.java | 11 +
.../apache/doris/catalog/TabletInvertedIndex.java | 14 +
.../main/java/org/apache/doris/catalog/View.java | 89 -
.../doris/cloud/CacheHotspotManagerUtils.java | 1 -
.../doris/cloud/catalog/CloudClusterChecker.java | 42 +-
.../doris/cloud/catalog/CloudTabletRebalancer.java | 510 ++--
.../doris/cloud/load/CloudBrokerLoadJob.java | 2 -
.../doris/cloud/load/CloudLoadLoadingTask.java | 2 -
.../apache/doris/cloud/load/CloudLoadManager.java | 8 -
.../transaction/CloudGlobalTransactionMgr.java | 5 +-
.../apache/doris/common/info/SimpleTableInfo.java | 66 -
.../doris/common/profile/ExecutionProfile.java | 33 +-
.../org/apache/doris/common/profile/Profile.java | 65 +-
.../doris/common/profile/RuntimeProfile.java | 37 +-
.../org/apache/doris/common/util/LocationPath.java | 595 ++--
.../java/org/apache/doris/common/util/Util.java | 10 +
.../org/apache/doris/datasource/CatalogIf.java | 31 +-
.../apache/doris/datasource/CatalogProperty.java | 58 +-
.../apache/doris/datasource/ExternalCatalog.java | 221 +-
.../apache/doris/datasource/ExternalDatabase.java | 119 +-
.../doris/datasource/ExternalMetaCacheMgr.java | 38 +-
.../doris/datasource/ExternalRowCountCache.java | 10 +-
.../apache/doris/datasource/ExternalScanNode.java | 18 -
.../doris/datasource/ExternalSchemaCache.java | 40 +-
.../org/apache/doris/datasource/ExternalTable.java | 31 +-
.../org/apache/doris/datasource/ExternalUtil.java | 83 +
.../apache/doris/datasource/FileQueryScanNode.java | 51 +-
.../org/apache/doris/datasource/FileScanNode.java | 3 -
.../org/apache/doris/datasource/FileSplit.java | 4 +-
.../org/apache/doris/datasource/FileSplitter.java | 2 +-
.../apache/doris/datasource/InternalCatalog.java | 499 +---
.../org/apache/doris/datasource/NameMapping.java | 88 +
.../apache/doris/datasource/SchemaCacheValue.java | 12 +
.../apache/doris/datasource/TableFormatType.java | 3 +-
.../doris/datasource/TablePartitionValues.java | 8 +-
.../doris/datasource/es/EsExternalDatabase.java | 5 -
.../doris/datasource/es/source/EsScanNode.java | 25 -
.../org/apache/doris/datasource/hive/AcidUtil.java | 8 +-
.../doris/datasource/hive/HMSExternalCatalog.java | 81 +-
.../doris/datasource/hive/HMSExternalTable.java | 86 +-
.../doris/datasource/hive/HMSTransaction.java | 171 +-
.../apache/doris/datasource/hive/HiveDlaTable.java | 8 +-
.../doris/datasource/hive/HiveMetaStoreCache.java | 290 +-
.../datasource/hive/HiveMetaStoreClientHelper.java | 3 +-
.../doris/datasource/hive/HiveMetadataOps.java | 190 +-
.../doris/datasource/hive/HivePartition.java | 28 +-
.../doris/datasource/hive/HiveProperties.java | 9 +-
.../doris/datasource/hive/HiveTransaction.java | 4 +-
.../org/apache/doris/datasource/hive/HiveUtil.java | 6 +-
.../apache/doris/datasource/hive/HudiDlaTable.java | 2 +-
.../doris/datasource/hive/IcebergDlaTable.java | 23 +-
.../datasource/hive/ThriftHMSCachedClient.java | 2 +-
.../hive/event/MetastoreEventsProcessor.java | 7 +-
.../doris/datasource/hive/source/HiveScanNode.java | 70 +-
.../doris/datasource/hudi/HudiSchemaCacheKey.java | 10 +-
.../apache/doris/datasource/hudi/HudiUtils.java | 121 +-
.../hudi/source/COWIncrementalRelation.java | 2 +-
.../hudi/source/HudiCachedFsViewProcessor.java | 5 +-
.../hudi/source/HudiCachedMetaClientProcessor.java | 35 +-
.../hudi/source/HudiCachedPartitionProcessor.java | 9 +-
.../hudi/source/HudiMetadataCacheMgr.java | 10 +-
.../hudi/source/HudiPartitionProcessor.java | 4 +-
.../doris/datasource/hudi/source/HudiScanNode.java | 43 +-
.../iceberg/IcebergDLFExternalCatalog.java | 26 +-
.../datasource/iceberg/IcebergExternalTable.java | 34 +-
.../iceberg/IcebergHadoopExternalCatalog.java | 19 +
.../datasource/iceberg/IcebergMetadataCache.java | 142 +-
.../iceberg/IcebergMetadataCacheMgr.java | 6 +-
.../datasource/iceberg/IcebergMetadataOps.java | 225 +-
.../datasource/iceberg/IcebergSchemaCacheKey.java | 5 +-
.../datasource/iceberg/IcebergTransaction.java | 26 +-
.../doris/datasource/iceberg/IcebergUtils.java | 148 +-
.../datasource/iceberg/fileio/DelegateFileIO.java | 243 ++
.../iceberg/fileio/DelegateInputFile.java | 117 +
.../iceberg/fileio/DelegateOutputFile.java | 197 ++
.../fileio/DelegateSeekableInputStream.java | 164 ++
.../iceberg/source/IcebergApiSource.java | 4 +-
.../iceberg/source/IcebergHMSSource.java | 11 +-
.../datasource/iceberg/source/IcebergScanNode.java | 24 +-
.../datasource/iceberg/source/IcebergSplit.java | 5 +-
.../doris/datasource/jdbc/source/JdbcScanNode.java | 36 -
.../doris/datasource/lakesoul/LakeSoulUtils.java | 4 -
.../datasource/lakesoul/source/LakeSoulSplit.java | 3 +-
.../maxcompute/MaxComputeMetadataCacheMgr.java | 8 +-
.../maxcompute/source/MaxComputeScanNode.java | 12 +-
.../doris/datasource/metacache/MetaCache.java | 14 +
.../doris/datasource/odbc/source/OdbcScanNode.java | 34 -
.../datasource/operations/ExternalMetadataOps.java | 137 +-
.../datasource/paimon/PaimonExternalCatalog.java | 17 +-
.../datasource/paimon/PaimonExternalTable.java | 28 +-
.../datasource/paimon/PaimonMetadataCache.java | 69 +-
.../datasource/paimon/PaimonMetadataCacheMgr.java | 6 +-
.../datasource/paimon/PaimonSchemaCacheKey.java | 5 +-
.../datasource/paimon/PaimonSnapshotCacheKey.java | 37 +-
.../apache/doris/datasource/paimon/PaimonUtil.java | 114 +
.../paimon/source/PaimonPredicateConverter.java | 6 -
.../datasource/paimon/source/PaimonScanNode.java | 37 +-
.../datasource/paimon/source/PaimonSplit.java | 5 +-
.../datasource/property/ConnectionProperties.java | 22 +-
.../property/ConnectorPropertiesUtils.java | 147 +
.../doris/datasource/property/ParamRules.java | 182 ++
.../doris/datasource/property/PropertyUtils.java | 46 -
...es.java => AWSGlueMetaStoreBaseProperties.java} | 97 +-
.../metastore/AWSGlueMetaStoreProperties.java | 77 +
.../property/metastore/AbstractHMSProperties.java | 64 +
.../metastore/AliyunDLFBaseProperties.java | 63 +
.../property/metastore/AliyunDLFProperties.java | 2 +-
.../metastore/HMSAliyunDLFMetaStoreProperties.java | 51 +
.../metastore/HMSGlueMetaStoreProperties.java | 114 +
.../property/metastore/HMSProperties.java | 163 +-
.../property/metastore/HMSPropertiesFactory.java | 51 +
.../property/metastore/MetastoreProperties.java | 133 +-
.../metastore/MetastorePropertiesFactory.java} | 11 +-
.../storage/AbstractS3CompatibleProperties.java | 51 +-
.../property/storage/AzureProperties.java | 10 +-
.../property/storage/BrokerProperties.java | 2 +-
.../datasource/property/storage/COSProperties.java | 8 +-
.../property/storage/HdfsProperties.java | 26 +-
.../property/storage/HdfsPropertiesUtils.java | 125 +-
.../property/storage/MinioProperties.java | 4 +-
.../datasource/property/storage/OBSProperties.java | 8 +-
.../property/storage/OSSHdfsProperties.java | 61 +-
.../datasource/property/storage/OSSProperties.java | 8 +-
.../datasource/property/storage/S3Properties.java | 46 +-
.../trinoconnector/source/TrinoConnectorSplit.java | 5 +-
.../datasource/tvf/source/MetadataScanNode.java | 11 -
.../doris/datasource/tvf/source/TVFScanNode.java | 16 +-
.../main/java/org/apache/doris/fs/FileSystem.java | 25 +
.../java/org/apache/doris/fs/FileSystemCache.java | 54 +-
.../apache/doris/fs/FileSystemProviderImpl.java | 13 +-
.../java/org/apache/doris/fs/SchemaTypeMapper.java | 156 ++
.../java/org/apache/doris/fs/io/DorisInput.java | 54 +
.../org/apache/doris/fs/io/DorisInputFile.java | 75 +
.../org/apache/doris/fs/io/DorisInputStream.java | 51 +
.../org/apache/doris/fs/io/DorisOutputFile.java | 59 +
.../InsertSource.java => fs/io/ParsedPath.java} | 29 +-
.../org/apache/doris/fs/io/hdfs/HdfsInput.java | 107 +
.../org/apache/doris/fs/io/hdfs/HdfsInputFile.java | 155 ++
.../apache/doris/fs/io/hdfs/HdfsInputStream.java | 180 ++
.../apache/doris/fs/io/hdfs/HdfsOutputFile.java | 95 +
.../apache/doris/fs/io/hdfs/HdfsOutputStream.java | 135 +
.../java/org/apache/doris/fs/obj/ObjStorage.java | 1 +
.../java/org/apache/doris/fs/obj/S3ObjStorage.java | 3 +-
.../doris/fs/remote/SwitchingFileSystem.java | 24 +-
.../apache/doris/fs/remote/dfs/DFSFileSystem.java | 82 +-
.../doris/httpv2/controller/BaseController.java | 2 -
.../org/apache/doris/httpv2/rest/LoadAction.java | 4 +-
.../doris/httpv2/rest/RestBaseController.java | 1 -
.../doris/job/extensions/insert/InsertTask.java | 1 -
.../apache/doris/journal/bdbje/BDBJEJournal.java | 2 +-
.../java/org/apache/doris/load/DeleteHandler.java | 50 -
.../org/apache/doris/load/ExportTaskExecutor.java | 1 -
.../org/apache/doris/load/GroupCommitManager.java | 4 +-
.../org/apache/doris/load/StreamLoadHandler.java | 1 -
.../org/apache/doris/load/loadv2/BulkLoadJob.java | 29 -
.../org/apache/doris/load/loadv2/LoadManager.java | 34 -
.../doris/load/loadv2/LoadManagerAdapter.java | 74 -
.../apache/doris/load/loadv2/MysqlLoadManager.java | 232 +-
.../load/routineload/KafkaRoutineLoadJob.java | 1 -
.../doris/load/routineload/KafkaTaskInfo.java | 1 -
.../doris/load/routineload/RoutineLoadJob.java | 11 +-
.../doris/load/routineload/RoutineLoadManager.java | 12 +-
.../load/routineload/RoutineLoadTaskScheduler.java | 4 +-
.../java/org/apache/doris/master/MasterImpl.java | 13 +-
.../java/org/apache/doris/mtmv/BaseTableInfo.java | 16 +
.../java/org/apache/doris/mtmv/MTMVPlanUtil.java | 2 -
.../java/org/apache/doris/mysql/MysqlProto.java | 1 -
.../org/apache/doris/mysql/privilege/Auth.java | 49 +-
.../org/apache/doris/mysql/privilege/Role.java | 46 +-
.../apache/doris/mysql/privilege/RoleManager.java | 2 +-
.../glue/translator/PhysicalPlanTranslator.java | 4 +
.../glue/translator/RuntimeFilterTranslator.java | 145 +-
.../doris/nereids/jobs/executor/Analyzer.java | 11 +
.../doris/nereids/jobs/executor/Rewriter.java | 23 +-
.../jobs/joinorder/hypergraph/HyperGraph.java | 3 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 152 +-
.../properties/ChildrenPropertiesRegulator.java | 6 +-
.../org/apache/doris/nereids/rules/RuleType.java | 3 +
.../nereids/rules/analysis/CheckAfterRewrite.java | 9 +-
.../rules/analysis/CollectOneLevelRelation.java} | 23 +-
.../nereids/rules/analysis/CollectRelation.java | 4 +-
.../rules/analysis/DatetimeFunctionBinder.java | 76 +-
.../rules/analysis/EliminateGroupByConstant.java | 83 -
.../nereids/rules/analysis/ExpressionAnalyzer.java | 90 +-
.../nereids/rules/analysis/SubqueryToApply.java | 191 +-
.../mv/InitMaterializationContextHook.java | 14 +-
.../ContainDistinctFunctionRollupHandler.java | 9 +-
.../rules/expression/ExpressionNormalization.java | 2 +
.../rules/expression/ExpressionRuleType.java | 4 +-
.../expression/rules/JsonFunctionRewrite.java | 64 +
.../rules/expression/rules/LikeToEqualRewrite.java | 4 +
.../rewrite/AggScalarSubQueryToWindowFunction.java | 11 +-
.../rules/rewrite/DistinctWindowExpression.java | 98 +
.../rules/rewrite/EliminateEmptyRelation.java | 18 +
.../nereids/rules/rewrite/PruneEmptyPartition.java | 31 +
.../doris/nereids/rules/rewrite/StatsDerive.java | 353 +++
.../rewrite/UnCorrelatedApplyAggregateFilter.java | 3 +-
.../rules/rewrite/UnCorrelatedApplyFilter.java | 2 +-
.../rewrite/UnCorrelatedApplyProjectFilter.java | 2 +-
.../mv/AbstractSelectMaterializedIndexRule.java | 776 ------
.../mv/SelectMaterializedIndexWithAggregate.java | 1699 ------------
.../SelectMaterializedIndexWithoutAggregate.java | 275 --
.../doris/nereids/stats/FilterEstimation.java | 47 +-
.../doris/nereids/stats/HboStatsCalculator.java | 13 +-
.../apache/doris/nereids/stats/JoinEstimation.java | 51 +-
.../doris/nereids/stats/StatsCalculator.java | 356 +--
.../trees/copier/LogicalPlanDeepCopier.java | 6 +-
.../nereids/trees/expressions/Expression.java | 14 +
.../doris/nereids/trees/expressions/Like.java | 55 +-
.../nereids/trees/expressions/ScalarSubquery.java | 84 +-
.../functions/ComputeSignatureHelper.java | 6 -
.../expressions/functions/agg/GroupConcat.java | 44 +-
.../functions/agg/MultiDistinctGroupConcat.java | 74 +-
.../functions/combinator/ForEachCombinator.java | 2 +-
.../functions/executable/DateTimeArithmetic.java | 10 +
.../functions/executable/NumericArithmetic.java | 35 +-
.../trees/expressions/functions/scalar/Cosec.java | 68 +
.../trees/expressions/functions/scalar/Cot.java | 68 +
.../expressions/functions/scalar/JsonArray.java | 13 +-
.../{JsonArray.java => JsonArrayIgnoreNull.java} | 25 +-
.../trees/expressions/functions/scalar/Sec.java | 68 +
.../trees/expressions/functions/scalar/Time.java | 68 +
.../trees/expressions/functions/scalar/ToJson.java | 96 +
.../expressions/literal/DateTimeV2Literal.java | 4 +
.../expressions/visitor/ScalarFunctionVisitor.java | 34 +-
.../doris/nereids/trees/plans/AbstractPlan.java | 6 +-
.../apache/doris/nereids/trees/plans/PlanType.java | 3 +
.../plans/commands/AlterColumnStatsCommand.java | 1 +
.../plans/commands/AlterStorageVaultCommand.java | 16 +
.../commands/CreateMaterializedViewCommand.java | 19 +-
.../trees/plans/commands/DropUserCommand.java | 8 -
.../trees/plans/commands/RestoreCommand.java | 419 +++
.../plans/commands/ShowCreateDatabaseCommand.java | 6 +-
.../plans/commands/ShowPartitionsCommand.java | 9 +-
.../plans/commands/ShowTableStatusCommand.java | 15 +-
.../plans/commands/StartTransactionCommand.java | 46 +
.../trees/plans/commands/info/AliasInfo.java | 4 +-
.../trees/plans/commands/info/AlterViewInfo.java | 2 +-
.../trees/plans/commands/info/BuildIndexOp.java | 2 -
.../trees/plans/commands/info/CreateIndexOp.java | 2 -
.../plans/commands/info/CreateRoutineLoadInfo.java | 1 -
.../trees/plans/commands/info/CreateUserInfo.java | 7 -
.../trees/plans/commands/info/CreateViewInfo.java | 2 +-
.../trees/plans/commands/info/DropIndexOp.java | 1 -
.../plans/commands/info/PartitionNamesInfo.java | 27 +-
.../trees/plans/commands/info/TableRefInfo.java | 3 +-
.../plans/commands/insert/HiveInsertExecutor.java | 6 +-
.../commands/insert/IcebergInsertExecutor.java | 16 +-
.../plans/commands/load/MysqlDataDescription.java | 277 ++
.../plans/commands/load/MysqlLoadCommand.java | 336 +++
.../trees/plans/logical/LogicalAggregate.java | 5 +-
.../nereids/trees/plans/logical/LogicalApply.java | 51 +-
.../trees/plans/logical/LogicalCTEConsumer.java | 5 +-
.../trees/plans/logical/LogicalCTEProducer.java | 5 +-
.../logical/LogicalDeferMaterializeOlapScan.java | 5 +-
.../logical/LogicalDeferMaterializeResultSink.java | 5 +-
.../plans/logical/LogicalDeferMaterializeTopN.java | 5 +-
.../nereids/trees/plans/logical/LogicalEsScan.java | 4 +-
.../nereids/trees/plans/logical/LogicalExcept.java | 5 +-
.../trees/plans/logical/LogicalFileScan.java | 5 +-
.../nereids/trees/plans/logical/LogicalFilter.java | 5 +-
.../trees/plans/logical/LogicalGenerate.java | 5 +-
.../nereids/trees/plans/logical/LogicalHaving.java | 3 +-
.../trees/plans/logical/LogicalHudiScan.java | 5 +-
.../trees/plans/logical/LogicalIntersect.java | 5 +-
.../nereids/trees/plans/logical/LogicalJoin.java | 5 +-
.../nereids/trees/plans/logical/LogicalLimit.java | 5 +-
.../trees/plans/logical/LogicalOlapScan.java | 10 +-
.../trees/plans/logical/LogicalPartitionTopN.java | 4 +-
.../trees/plans/logical/LogicalProject.java | 5 +-
.../nereids/trees/plans/logical/LogicalUnion.java | 5 +-
.../trees/plans/logical/LogicalUsingJoin.java | 5 +-
.../nereids/trees/plans/logical/LogicalWindow.java | 5 +-
.../trees/plans/visitor/CommandVisitor.java | 16 +
.../apache/doris/nereids/types/AggStateType.java | 4 +
.../org/apache/doris/nereids/types/DataType.java | 4 +
.../org/apache/doris/nereids/util/PlanUtils.java | 19 +
.../apache/doris/nereids/util/RelationUtil.java | 3 -
.../doris/nereids/util/TypeCoercionUtils.java | 20 +-
.../java/org/apache/doris/nereids/util/Utils.java | 59 +-
.../org/apache/doris/planner/AggregationNode.java | 212 --
.../org/apache/doris/planner/AnalyticEvalNode.java | 82 -
.../apache/doris/planner/AssertNumRowsNode.java | 25 -
.../planner/BackendPartitionedSchemaScanNode.java | 14 -
.../java/org/apache/doris/planner/CTEScanNode.java | 4 -
.../org/apache/doris/planner/DataGenScanNode.java | 28 -
.../org/apache/doris/planner/EmptySetNode.java | 31 -
.../java/org/apache/doris/planner/ExceptNode.java | 9 -
.../org/apache/doris/planner/ExchangeNode.java | 58 -
.../org/apache/doris/planner/FileLoadScanNode.java | 291 --
.../apache/doris/planner/GroupCommitPlanner.java | 24 -
.../apache/doris/planner/GroupCommitScanNode.java | 5 -
.../doris/planner/HashDistributionPruner.java | 5 +-
.../org/apache/doris/planner/HashJoinNode.java | 498 ----
.../org/apache/doris/planner/HiveTableSink.java | 20 +-
.../org/apache/doris/planner/IcebergTableSink.java | 3 +-
.../org/apache/doris/planner/IntersectNode.java | 8 -
.../org/apache/doris/planner/JoinNodeBase.java | 458 ----
.../apache/doris/planner/MaterializationNode.java | 24 -
.../doris/planner/MaterializedViewSelector.java | 769 ------
.../org/apache/doris/planner/MysqlScanNode.java | 180 --
.../apache/doris/planner/NestedLoopJoinNode.java | 72 -
.../org/apache/doris/planner/OlapScanNode.java | 695 -----
.../org/apache/doris/planner/OlapTableSink.java | 15 +-
.../apache/doris/planner/PartitionSortNode.java | 4 -
.../org/apache/doris/planner/PlanFragment.java | 10 +-
.../java/org/apache/doris/planner/PlanNode.java | 473 ----
.../org/apache/doris/planner/PlannerContext.java | 61 -
.../java/org/apache/doris/planner/RepeatNode.java | 99 -
.../java/org/apache/doris/planner/ScanNode.java | 161 --
.../org/apache/doris/planner/SchemaScanNode.java | 17 -
.../java/org/apache/doris/planner/SelectNode.java | 48 -
.../org/apache/doris/planner/SetOperationNode.java | 288 --
.../java/org/apache/doris/planner/SortNode.java | 129 -
.../apache/doris/planner/TableFunctionNode.java | 123 -
.../doris/planner/TestExternalTableScanNode.java | 93 -
.../java/org/apache/doris/planner/UnionNode.java | 8 -
.../org/apache/doris/plugin/audit/AuditLoader.java | 6 +-
.../java/org/apache/doris/qe/AuditLogHelper.java | 14 -
.../java/org/apache/doris/qe/ConnectContext.java | 15 +-
.../org/apache/doris/qe/ConnectContextUtil.java | 42 +
.../java/org/apache/doris/qe/ConnectProcessor.java | 11 +-
.../main/java/org/apache/doris/qe/Coordinator.java | 10 +-
.../main/java/org/apache/doris/qe/DdlExecutor.java | 10 -
.../org/apache/doris/qe/MysqlConnectProcessor.java | 1 -
.../java/org/apache/doris/qe/SessionVariable.java | 10 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 1135 +-------
.../main/java/org/apache/doris/qe/VariableMgr.java | 10 +-
.../main/java/org/apache/doris/qe/cache/Cache.java | 15 -
.../org/apache/doris/qe/cache/CacheAnalyzer.java | 305 +--
.../org/apache/doris/qe/cache/PartitionCache.java | 236 --
.../java/org/apache/doris/qe/cache/SqlCache.java | 11 +-
.../resource/workloadgroup/WorkloadGroupMgr.java | 7 +-
.../doris/rewrite/BetweenToCompoundRule.java | 69 -
.../org/apache/doris/rewrite/CaseWhenToIf.java | 52 -
.../doris/rewrite/CompoundPredicateWriteRule.java | 107 -
.../doris/rewrite/ElementAtToSlotRefRule.java | 136 -
.../rewrite/EliminateUnnecessaryFunctions.java | 48 -
.../doris/rewrite/EraseRedundantCastExpr.java | 70 -
.../org/apache/doris/rewrite/ExprRewriteRule.java | 47 -
.../org/apache/doris/rewrite/ExprRewriter.java | 293 --
.../doris/rewrite/ExtractCommonFactorsRule.java | 648 -----
.../apache/doris/rewrite/FoldConstantsRule.java | 450 ---
.../org/apache/doris/rewrite/FunctionAlias.java | 60 -
.../org/apache/doris/rewrite/InferFiltersRule.java | 681 -----
.../apache/doris/rewrite/MatchPredicateRule.java | 41 -
.../rewrite/NormalizeBinaryPredicatesRule.java | 55 -
.../doris/rewrite/RewriteAliasFunctionRule.java | 51 -
.../doris/rewrite/RewriteBinaryPredicatesRule.java | 138 -
.../doris/rewrite/RewriteDateLiteralRule.java | 82 -
.../doris/rewrite/RewriteEncryptKeyRule.java | 45 -
.../doris/rewrite/RewriteFromUnixTimeRule.java | 163 --
.../doris/rewrite/RewriteImplicitCastRule.java | 106 -
.../doris/rewrite/RewriteInPredicateRule.java | 143 -
.../doris/rewrite/RewriteIsNullIsNotNullRule.java | 55 -
.../RoundLiteralInBinaryPredicatesRule.java | 165 --
.../rewrite/mvrewrite/CountDistinctToBitmap.java | 103 -
.../mvrewrite/CountDistinctToBitmapOrHLLRule.java | 72 -
.../doris/rewrite/mvrewrite/CountFieldToSum.java | 46 -
.../doris/rewrite/mvrewrite/ExprToSlotRefRule.java | 289 --
.../rewrite/mvrewrite/FunctionCallEqualRule.java | 80 -
.../rewrite/mvrewrite/HLLHashToSlotRefRule.java | 116 -
.../doris/rewrite/mvrewrite/MVExprEquivalent.java | 106 -
.../apache/doris/rewrite/mvrewrite/NDVToHll.java | 101 -
.../doris/rewrite/mvrewrite/SlotRefEqualRule.java | 49 -
.../rewrite/mvrewrite/ToBitmapToSlotRefRule.java | 115 -
.../apache/doris/service/FrontendServiceImpl.java | 87 +-
.../sessions/FlightSessionsManager.java | 1 -
.../org/apache/doris/statistics/AnalysisJob.java | 2 +-
.../apache/doris/statistics/BaseAnalysisTask.java | 142 +-
.../org/apache/doris/statistics/ColStatsData.java | 10 +-
.../apache/doris/statistics/ColumnStatistic.java | 42 +-
.../doris/statistics/ColumnStatisticBuilder.java | 18 +-
.../apache/doris/statistics/HMSAnalysisTask.java | 4 +-
.../apache/doris/statistics/OlapAnalysisTask.java | 5 +-
.../PartitionColumnStatisticBuilder.java | 2 +-
.../doris/statistics/StatisticConstants.java | 10 +
.../org/apache/doris/statistics/Statistics.java | 5 +-
.../apache/doris/statistics/StatisticsCache.java | 2 +-
.../doris/statistics/StatisticsRepository.java | 13 +-
.../org/apache/doris/statistics/StatsType.java | 1 +
.../doris/statistics/util/StatisticsUtil.java | 34 +-
.../org/apache/doris/system/SystemInfoService.java | 2 +-
.../ExternalFileTableValuedFunction.java | 27 +-
.../tablefunction/IcebergTableValuedFunction.java | 20 +-
.../tablefunction/LocalTableValuedFunction.java | 4 +-
.../doris/tablefunction/MetadataGenerator.java | 115 +-
.../doris/transaction/GlobalTransactionMgr.java | 6 +-
.../transaction/GlobalTransactionMgrIface.java | 22 +-
.../apache/doris/transaction/TransactionEntry.java | 26 +
.../org/apache/doris/alter/AlterJobV2Test.java | 34 +-
.../org/apache/doris/alter/BatchRollupJobTest.java | 16 +-
.../org/apache/doris/alter/CloudIndexTest.java | 1 -
.../org/apache/doris/alter/RollupJobV2Test.java | 29 +-
.../org/apache/doris/analysis/AggregateTest.java | 572 ----
.../doris/analysis/BetweenPredicateTest.java | 54 -
.../doris/analysis/ComparisonPredicateTest.java | 79 -
.../apache/doris/analysis/CreateJobStmtTest.java | 53 -
.../analysis/CreateMaterializedViewStmtTest.java | 1120 --------
.../apache/doris/analysis/CreateTableStmtTest.java | 524 ----
.../org/apache/doris/analysis/DeleteStmtTest.java | 188 --
.../apache/doris/analysis/InsertArrayStmtTest.java | 110 -
.../org/apache/doris/analysis/InsertStmtTest.java | 300 --
.../doris/analysis/OutFileClauseFunctionTest.java | 135 -
.../org/apache/doris/analysis/QueryStmtTest.java | 402 ---
.../doris/analysis/SetOperationStmtTest.java | 82 -
.../org/apache/doris/analysis/SqlModeTest.java | 116 -
.../org/apache/doris/backup/BackupHandlerTest.java | 7 +-
.../apache/doris/catalog/ColocateTableTest.java | 23 +-
.../apache/doris/catalog/CreateFunctionTest.java | 21 +-
.../apache/doris/catalog/CreateTableLikeTest.java | 11 +-
.../org/apache/doris/catalog/CreateTableTest.java | 31 +-
.../CreateTableWithBloomFilterIndexTest.java | 4 +-
.../org/apache/doris/catalog/CreateViewTest.java | 21 +-
.../java/org/apache/doris/catalog/DropDbTest.java | 13 +-
.../doris/catalog/DropMaterializedViewTest.java | 10 +-
.../apache/doris/catalog/DropPartitionTest.java | 13 +-
.../org/apache/doris/catalog/DropTableTest.java | 13 +-
.../doris/catalog/DynamicPartitionTableTest.java | 23 +-
.../org/apache/doris/catalog/EnvOperationTest.java | 13 +-
.../catalog/InternalSchemaInitializerTest.java | 61 +-
.../org/apache/doris/catalog/OlapTableTest.java | 4 +-
.../java/org/apache/doris/catalog/RecoverTest.java | 13 +-
.../apache/doris/catalog/TruncateTableTest.java | 257 --
.../catalog/constraint/ConstraintPersistTest.java | 198 +-
.../ColocateTableCheckerAndBalancerPerfTest.java | 17 +-
.../org/apache/doris/clone/DecommissionTest.java | 13 +-
.../doris/clone/TabletRepairAndBalanceTest.java | 15 +-
.../doris/clone/TabletReplicaTooSlowTest.java | 14 +-
.../doris/common/profile/ProfileStructureTest.java | 130 +
.../common/profile/RuntimeProfileMergeTest.java | 4 +-
.../apache/doris/common/util/LocationPathTest.java | 329 +--
.../doris/datasource/TestHMSCachedClient.java | 14 +-
.../apache/doris/datasource/hive/HiveAcidTest.java | 69 +-
.../datasource/hive/HiveMetaStoreCacheTest.java | 21 +-
.../doris/datasource/hive/HiveMetadataOpsTest.java | 17 +-
.../doris/datasource/hive/HmsCommitTest.java | 8 +-
.../datasource/iceberg/CreateIcebergTableTest.java | 17 +-
.../IcebergExternalTableBranchAndTagTest.java | 85 +-
.../datasource/iceberg/IcebergTransactionTest.java | 145 +-
.../dlf/client/IcebergDLFExternalCatalogTest.java | 13 +-
.../paimon/PaimonExternalCatalogTest.java | 43 -
.../paimon/source/PaimonScanNodeTest.java | 10 +-
.../property/ConnectorPropertiesUtilsTest.java | 164 ++
.../doris/datasource/property/ParamRulesTest.java | 118 +
.../datasource/property/PropertyConverterTest.java | 133 +-
.../property/PropertyPassThroughTest.java | 68 -
...st.java => AWSGlueMetaStorePropertiesTest.java} | 38 +-
.../metastore/AliyunDLFPropertiesTest.java | 2 +
.../property/metastore/GlueCatalogTest.java | 4 +-
.../metastore/HMSGlueMetaStorePropertiesTest.java | 108 +
.../property/metastore/HMSPropertiesTest.java | 69 +-
.../property/storage/HdfsPropertiesUtilsTest.java | 18 +-
.../property/storage/OSSHdfsPropertiesTest.java | 14 +-
...st.java => S3ConnectorPropertiesUtilsTest.java} | 2 +-
.../property/storage/S3PropertiesTest.java | 15 +-
.../tvf/FileTableValuedFunctionTest.java | 134 -
.../apache/doris/external/hms/HmsCatalogTest.java | 11 +-
.../external/iceberg/IcebergHadoopCatalogTest.java | 2 +-
.../org/apache/doris/fs/SchemaTypeMapperTest.java | 67 +
.../org/apache/doris/load/DeleteHandlerTest.java | 469 ----
.../load/routineload/RoutineLoadManagerTest.java | 2 +-
.../apache/doris/mysql/ConnectionExceedTest.java | 10 +-
.../org/apache/doris/mysql/privilege/AuthTest.java | 48 +
.../rules/analysis/AnalyzeSubQueryTest.java | 93 +
.../nereids/rules/analysis/CheckRowPolicyTest.java | 22 +-
.../rules/analysis/DatetimeFunctionBinderTest.java | 356 ++-
.../rules/analysis/ExpressionAnalyzerTest.java | 63 +
.../nereids/rules/analysis/GenerateFunction.java | 1 +
.../rules/analysis/SubqueryToApplyTest.java | 67 +
.../rules/rewrite/ExistsApplyToJoinTest.java | 8 +-
.../rules/rewrite/PruneOlapScanPartitionTest.java | 10 +-
.../mv/BaseMaterializedIndexSelectTest.java | 51 -
.../rules/rewrite/mv/SelectMvIndexTest.java | 1334 ---------
.../rules/rewrite/mv/SelectRollupIndexTest.java | 498 ----
.../doris/nereids/stats/FilterEstimationTest.java | 45 +-
.../doris/nereids/stats/StatsCalculatorTest.java | 10 +-
.../nereids/trees/plans/PlanToStringTest.java | 12 +-
.../trees/plans/commands/AlterUserCommandTest.java | 4 +-
.../plans/commands/CreateUserCommandTest.java | 1 -
.../trees/plans/commands/MysqlLoadCommandTest.java | 117 +
.../trees/plans/commands/RestoreCommandTest.java | 139 +
.../doris/nereids/util/HyperGraphBuilder.java | 2 +-
.../apache/doris/nereids/util/MemoTestUtils.java | 1 -
.../doris/planner/FederationBackendPolicyTest.java | 173 +-
.../apache/doris/planner/HiveTableSinkTest.java | 4 +-
.../doris/planner/ListPartitionPrunerV2Test.java | 15 +-
.../planner/MaterializedViewFunctionTest.java | 864 ------
.../planner/MaterializedViewSelectorTest.java | 492 ----
.../apache/doris/planner/ResourceTagQueryTest.java | 12 +-
.../org/apache/doris/planner/SqlDigestTest.java | 142 -
.../org/apache/doris/qe/ConnectContextTest.java | 9 +-
.../org/apache/doris/qe/ConnectSchedulerTest.java | 5 +-
.../org/apache/doris/qe/HmsQueryCacheTest.java | 469 +---
.../java/org/apache/doris/qe/LocalShuffleTest.java | 222 ++
.../org/apache/doris/qe/OlapQueryCacheTest.java | 8 +-
.../java/org/apache/doris/qe/SetExecutorTest.java | 1 -
.../java/org/apache/doris/qe/ShowExecutorTest.java | 3 +-
.../apache/doris/resource/ComputeGroupTest.java | 7 +-
.../rewrite/ExtractCommonFactorsRuleTest.java | 160 --
.../doris/rewrite/RewriteImplicitCastRuleTest.java | 61 -
.../doris/service/FrontendServiceImplTest.java | 13 +-
.../apache/doris/statistics/AnalysisJobTest.java | 2 +-
.../doris/statistics/BaseAnalysisTaskTest.java | 8 +-
.../org/apache/doris/statistics/CacheTest.java | 4 +-
.../apache/doris/statistics/ColStatsDataTest.java | 139 +-
.../doris/statistics/HMSAnalysisTaskTest.java | 24 +-
.../doris/statistics/OlapAnalysisTaskTest.java | 59 +-
.../statistics/StatisticsAutoCollectorTest.java | 16 +-
.../org/apache/doris/statistics/StatsMockUtil.java | 1 +
.../doris/statistics/util/StatisticsUtilTest.java | 53 +-
.../org/apache/doris/utframe/AnotherDemoTest.java | 14 +-
.../doris/utframe/DemoMultiBackendsTest.java | 14 +-
.../java/org/apache/doris/utframe/DorisAssert.java | 35 +-
.../apache/doris/utframe/TestWithFeService.java | 54 +-
.../org/apache/doris/utframe/UtFrameUtils.java | 65 -
gensrc/proto/cloud.proto | 279 +-
.../util/errno.h => gensrc/proto/file_cache.proto | 37 +-
gensrc/proto/olap_file.proto | 9 +
gensrc/thrift/Descriptors.thrift | 5 +-
gensrc/thrift/ExternalTableSchema.thrift | 65 +
gensrc/thrift/FrontendService.thrift | 1 +
gensrc/thrift/PlanNodes.thrift | 8 +-
.../data/audit/test_audit_log_behavior.out | Bin 1231 -> 1838 bytes
regression-test/data/cast_p0/cast_to_time.out | Bin 1986 -> 2164 bytes
.../data/correctness/test_cast_as_time.out | Bin 409 -> 410 bytes
.../data/correctness_p0/test_array_order_by.out | Bin 845 -> 3891 bytes
.../correctness_p0/test_array_string_order_by.out | Bin 0 -> 5109 bytes
.../import/import-way/broker-load-manual.md.out | Bin 810 -> 813 bytes
.../data/empty_relation/eliminate_empty.out | Bin 3183 -> 3681 bytes
.../hive/test_hive_case_sensibility.out | Bin 0 -> 4125 bytes
.../hive/test_hive_parquet_skip_page.out | Bin 31833 -> 31867 bytes
.../hive/test_multi_delimit_serde.out | Bin 0 -> 484 bytes
.../iceberg/test_iceberg_case_sensibility.out | Bin 1357 -> 0 bytes
.../iceberg/test_iceberg_full_schema_change.out | Bin 0 -> 69507 bytes
.../test_iceberg_hadoop_case_sensibility.out | Bin 0 -> 3876 bytes
.../iceberg/test_iceberg_hms_case_sensibility.out | Bin 0 -> 4623 bytes
.../iceberg/test_iceberg_rest_case_sensibility.out | Bin 0 -> 3796 bytes
.../paimon/test_paimon_full_schema_change.out | Bin 0 -> 31145 bytes
.../hudi/test_hudi_full_schema_change.out | Bin 0 -> 34801 bytes
.../cloud/test_cloud_mow_sc_inc_rowsets_dup.out} | Bin 189 -> 197 bytes
.../inverted_index_p0/load/test_stream_load.out | Bin 407 -> 329 bytes
.../test_index_match_phrase_ordered.out | Bin 441 -> 442 bytes
.../data/json_p0/test_json_load_and_function.out | Bin 261681 -> 260921
bytes
.../test_json_load_unique_key_and_function.out | Bin 87033 -> 87183 bytes
.../data/jsonb_p0/test_json_to_json.out | Bin 0 -> 2295 bytes
.../data/jsonb_p0/test_jsonb_load_and_function.out | Bin 189687 -> 189088
bytes
.../test_jsonb_load_unique_key_and_function.out | Bin 124394 -> 124355
bytes
.../agg_function/test_agg_case_sensitive.out} | Bin 135 -> 139 bytes
.../data/nereids_function_p0/scalar_function/J.out | Bin 160933 -> 160505
bytes
.../data/nereids_p0/datatype/test_cast.out | Bin 1346 -> 1350 bytes
.../data/nereids_p0/hint/multi_leading.out | Bin 9186 -> 9171 bytes
.../multi_distinct/multi_distinct_window.out | Bin 0 -> 309 bytes
.../runtime_filter/cte-runtime-filter.out | Bin 0 -> 1411 bytes
.../subquery/correlated_scalar_subquery.out | Bin 736 -> 866 bytes
.../adjust_nullable/test_subquery_nullable.out | Bin 0 -> 6295 bytes
.../limit_push_down/order_push_down.out | Bin 19605 -> 21201 bytes
.../query_p0/group_concat/test_group_concat.out | Bin 1132 -> 1184 bytes
.../query_p0/schema_table/test_view_dependency.out | Bin 0 -> 1473 bytes
.../test_aggregate_all_functions.out | Bin 2765 -> 2803 bytes
.../datetime_functions/test_func_time.out | Bin 0 -> 887 bytes
.../json_function/test_query_json_array.out | Bin 1395 -> 1888 bytes
.../json_functions/test_json_extract.out | Bin 279 -> 758 bytes
.../json_functions/test_mapagg_with_jsonfuncs.out | Bin 189 -> 142 bytes
.../sql_functions/math_functions/test_triangle.out | Bin 0 -> 1103 bytes
.../string_functions/test_like_escape.out | Bin 0 -> 333 bytes
.../string_functions/test_like_literal.out | Bin 0 -> 565 bytes
.../string_functions/test_like_table.out | Bin 0 -> 1545 bytes
.../window_functions/test_window_fn.out | Bin 7822 -> 16313 bytes
.../load.out | Bin
.../sql/affinityByIssuesAndPRs1.out | Bin
.../sql/affinityByIssuesAndPRs2.out | Bin
.../sql/authorsWithTheMostPushes.out | Bin
.../sql/countingStar1.out | Bin
.../sql/countingStar2.out | Bin
.../sql/countingStar3.out | Bin
.../sql/distributionOfRepositoriesByStarCount.out | Bin
.../sql/githubRoulette.out | Bin
...heListOfTopRepositoriesChangedOverTheYears1.out | Bin
...heListOfTopRepositoriesChangedOverTheYears2.out | Bin
...heListOfTopRepositoriesChangedOverTheYears3.out | Bin
...heListOfTopRepositoriesChangedOverTheYears4.out | Bin
...heListOfTopRepositoriesChangedOverTheYears5.out | Bin
...heListOfTopRepositoriesChangedOverTheYears6.out | Bin
.../howHasTheTotalNumberOfStarsChangedOverTime.out | Bin
.../sql/issuesWithTheMostComments1.out | Bin
.../sql/issuesWithTheMostComments2.out | Bin
.../sql/issuesWithTheMostComments3.out | Bin
.../sql/issuesWithTheMostComments4.out | Bin
.../sql/issuesWithTheMostComments5.out | Bin
.../sql/issuesWithTheMostComments6.out | Bin
.../sql/issuesWithTheMostComments7.out | Bin
.../sql/mostForkedRepositories.out | Bin
.../sql/mostPopularCommentsOnGithub.out | Bin
.../sql/organizationsByTheNumberOfRepositories.out | Bin
.../sql/organizationsByTheNumberOfStars.out | Bin
.../sql/proportionsBetweenStarsAndForks1.out | Bin
.../sql/proportionsBetweenStarsAndForks2.out | Bin
.../sql/proportionsBetweenStarsAndForks3.out | Bin
.../sql/proportionsBetweenStarsAndForks4.out | Bin
.../sql/proportionsBetweenStarsAndForks5.out | Bin
.../sql/repositoriesByAmountOfModifiedCode.out | Bin
.../sql/repositoriesByTheNumberOfPushes.out | Bin
...epositoriesWithClickhouse_related_comments1.out | Bin
...epositoriesWithClickhouse_related_comments2.out | Bin
.../repositoriesWithDoris_related_comments1.out | Bin
.../repositoriesWithDoris_related_comments2.out | Bin
.../sql/repositoriesWithTheHighestGrowthYoY.out | Bin
.../repositoriesWithTheMaximumAmountOfIssues1.out | Bin
.../repositoriesWithTheMaximumAmountOfIssues2.out | Bin
.../repositoriesWithTheMaximumAmountOfIssues3.out | Bin
.../repositoriesWithTheMaximumAmountOfIssues4.out | Bin
...sitoriesWithTheMaximumAmountOfPullRequests1.out | Bin
...sitoriesWithTheMaximumAmountOfPullRequests2.out | Bin
...esWithTheMaximumNumberOfAcceptedInvitations.out | Bin
...sitoriesWithTheMostPeopleWhoHavePushAccess1.out | Bin
.../repositoriesWithTheMostStarsOverOneDay1.out | Bin
...repositoriesWithTheMostSteadyGrowthOverTime.out | Bin
.../repositoriesWithTheWorstStagnation_order.out | Bin
.../sql/repositoryAffinityList1.out | Bin
.../sql/repositoryAffinityList2.out | Bin
.../sql/starsFromHeavyGithubUsers1.out | Bin
.../sql/starsFromHeavyGithubUsers2.out | Bin
.../sql/test_distinct_streaming_agg.out | Bin
.../sql/theLongestRepositoryNames1.out | Bin
.../sql/theLongestRepositoryNames2.out | Bin
.../sql/theMostToughCodeReviews.out | Bin
.../sql/theTotalNumberOfRepositoriesOnGithub.out | Bin
.../sql/theTotalNumberOfUsersOnGithub1.out | Bin
.../sql/theTotalNumberOfUsersOnGithub2.out | Bin
.../sql/theTotalNumberOfUsersOnGithub3.out | Bin
.../sql/theTotalNumberOfUsersOnGithub4.out | Bin
.../sql/topRepositoriesByStars.out | Bin
.../sql/whatIsTheBestDayOfTheWeekToCatchAStar.out | Bin
.../sql/whoAreAllThosePeopleGivingStars1.out | Bin
.../sql/whoAreAllThosePeopleGivingStars2.out | Bin
.../sql/whoAreAllThosePeopleGivingStars3.out | Bin
regression-test/data/variant_p0/desc.out | Bin 5397 -> 5887 bytes
regression-test/data/variant_p0/escaped_chars.out | Bin 0 -> 1177 bytes
.../compaction/test_compaction_extract_root.out | Bin 268 -> 291 bytes
.../org/apache/doris/regression/suite/Suite.groovy | 219 +-
.../doris/regression/suite/SuiteCluster.groovy | 4 +
.../apache/doris/regression/util/DebugPoint.groovy | 18 +
.../apache/doris/regression/util/JdbcUtils.groovy | 18 +-
regression-test/pipeline/cloud_p0/clean.sh | 2 +-
regression-test/pipeline/cloud_p0/run.sh | 20 +-
regression-test/pipeline/common/doris-utils.sh | 100 +-
.../nonConcurrent/conf/regression-conf.groovy | 1 +
regression-test/pipeline/vault_p0/clean.sh | 3 +-
regression-test/pipeline/vault_p0/prepare.sh | 4 +-
regression-test/pipeline/vault_p0/run.sh | 20 +-
.../suites/account_p0/test_grant_priv.groovy | 38 +
.../multi_cluster/test_change_node_net.groovy | 102 +
.../correctness_p0/test_array_order_by.groovy | 37 +-
.../test_array_string_order_by.groovy | 62 +
.../one_level_nestedtypes_with_s3data.groovy | 21 -
.../suites/demo_p0/test_lru_persist.groovy | 94 +
.../import/import-way/broker-load-manual.md.groovy | 5 +-
.../suites/empty_relation/eliminate_empty.groovy | 21 +-
.../hive/ddl/test_hive_ctas.groovy | 4 +-
.../hive/ddl/test_hive_database.groovy | 54 -
.../hive/test_hive_case_sensibility.groovy | 358 +++
.../hive/test_hive_parquet_skip_page.groovy | 12 +-
.../hive/test_hive_statistic.groovy | 2 +-
.../hive/test_multi_delimit_serde.groovy | 84 +
.../iceberg/test_iceberg_case_sensibility.groovy | 218 --
.../iceberg/test_iceberg_full_schema_change.groovy | 116 +
.../test_iceberg_hadoop_case_sensibility.groovy | 343 +++
.../test_iceberg_hms_case_sensibility.groovy | 357 +++
.../test_iceberg_rest_case_sensibility.groovy | 344 +++
.../iceberg/test_iceberg_show_create.groovy | 5 +-
.../iceberg/write/test_iceberg_create_table.groovy | 4 +-
...ceberg_insert_overwrite_with_empty_table.groovy | 7 +-
.../paimon/test_paimon_catalog.groovy | 6 +
.../paimon/test_paimon_full_schema_change.groovy | 80 +
.../tvf/test_file_tvf_hdfs.groovy | 10 +-
.../tvf/test_hdfs_parquet_group4.groovy | 2 +-
.../tvf/test_hdfs_parquet_group6.groovy | 2 +-
.../external_table_p0/tvf/upgrade/load.groovy | 12 +-
.../external_table_p0/tvf/upgrade/test.groovy | 6 +-
.../hudi/test_hudi_full_schema_change.groovy | 151 +
.../cloud/test_cloud_mow_sc_inc_rowsets_dup.groovy | 103 +
.../test_inverted_index_v3_fault_injection.groovy | 3 +-
...inverted_index_exception_fault_injection.groovy | 12 +-
.../suites/insert_p0/test_insert_timeout.groovy | 59 +
.../suites/insert_p0/transaction/txn_insert.groovy | 22 +
.../inverted_index_p0/load/test_stream_load.groovy | 6 -
...sted_index_file_http_action_with_variant.groovy | 1 -
.../suites/jsonb_p0/test_json_to_json.groovy | 217 ++
.../load_p0/stream_load/test_sink_tolerate.groovy | 121 +
.../suites/manager/test_manager_interface_1.groovy | 2 +-
.../suites/mtmv_p0/test_iceberg_mtmv.groovy | 5 +-
.../agg_use_key_direct/agg_use_key_direct.groovy | 6 +-
.../test_create_mv_complex_type.groovy | 18 -
.../agg_function/test_agg_case_sensitive.groovy | 64 +
.../test_outerjoin_isnull_estimation.groovy | 52 +-
.../expression/expression_depth_check.groovy | 56 +
.../fold_constant_numeric_arithmatic.groovy | 36 +
.../suites/nereids_p0/hint/multi_leading.groovy | 1 +
.../suites/nereids_p0/hint/test_use_mv.groovy | 35 -
.../suites/nereids_p0/join/test_join_on.groovy | 4 -
.../multi_distinct/multi_distinct_window.groovy | 45 +
.../runtime_filter/cte-runtime-filter.groovy | 71 +
.../subquery/correlated_scalar_subquery.groovy | 5 +
...st_unsupported_start_transaction_command.groovy | 10 +-
.../adjust_nullable/test_subquery_nullable.groovy | 92 +
.../lazy_materialize_topn.groovy | 4 +-
.../mv/availability/grace_period.groovy | 16 +-
.../mv/date_trunc/mv_with_date_trunc.groovy | 2 +-
.../external_table/part_partition_invalid.groovy | 17 +-
.../mv/external_table/single_external_table.groovy | 6 +-
.../mv/join/inner/inner_join_x.groovy | 2 -
.../partition_mv_rewrite.groovy | 34 +-
.../union_all_compensate.groovy | 12 +-
.../partition_curd_union_rewrite.groovy | 4 +-
.../mv/union_rewrite/usercase_union_rewrite.groovy | 4 +-
.../unioin_rewrite_grace_big.groovy | 36 +-
.../aggregate_group_by_metric_type.groovy | 18 -
.../query_p0/group_concat/test_group_concat.groovy | 26 +-
.../schema_table/test_view_dependency.groovy | 101 +
.../test_aggregate_all_functions.groovy | 1 +
.../datetime_functions/test_func_time.groovy | 80 +
.../json_function/test_query_json_array.groovy | 58 +-
.../json_functions/test_json_extract.groovy | 72 +-
.../math_functions/test_triangle.groovy | 58 +-
.../string_functions/test_like_escape.groovy | 71 +
.../string_functions/test_like_literal.groovy | 96 +
.../string_functions/test_like_table.groovy | 77 +
.../window_functions/test_window_fn.groovy | 273 +-
.../rollup_p0/test_create_mv_and_mtmv.groovy | 2 -
...t_unique_schema_key_change_multi_tablets.groovy | 391 +++
regression-test/suites/statistics/test_ddl.groovy | 2 +-
.../suites/statistics/test_hot_value.groovy | 196 ++
.../load.groovy | 12 +-
.../load.groovy | 1 -
.../suites/variant_log_data_p2/load.groovy | 4 -
regression-test/suites/variant_p0/desc.groovy | 6 +-
.../suites/variant_p0/escaped_chars.groovy | 71 +
.../suites/variant_p0/with_index/load.groovy | 16 +-
.../with_index/test_array_index_write.groovy | 4 +-
.../compaction/compaction_sparse_column.groovy | 46 +-
.../compaction/test_compaction_extract_root.groovy | 44 +-
regression-test/suites/variant_p2/load.groovy | 31 +-
.../vault_p0/alter/test_alter_vault_type.groovy | 18 +
.../vault_p0/default/test_default_vault.groovy | 10 +
thirdparty/build-thirdparty.sh | 20 +-
.../patches/thrift-0.16-fix_mutex_include.patch | 9 +
ui/package.json | 8 +-
1376 files changed, 38336 insertions(+), 51716 deletions(-)
create mode 100644 be/benchmark/benchmark_bit_pack.cpp
create mode 100644
be/src/exec/schema_scanner/schema_view_dependency_scanner.cpp
copy be/src/{util/errno.cpp =>
exec/schema_scanner/schema_view_dependency_scanner.h} (50%)
create mode 100644 be/src/io/cache/cache_lru_dumper.cpp
create mode 100644 be/src/io/cache/cache_lru_dumper.h
create mode 100644 be/src/io/cache/lru_queue_recorder.cpp
create mode 100644 be/src/io/cache/lru_queue_recorder.h
rename be/src/olap/rowset/segment_v2/{inverted_index_file_reader.cpp =>
index_file_reader.cpp} (93%)
rename be/src/olap/rowset/segment_v2/{inverted_index_file_reader.h =>
index_file_reader.h} (90%)
create mode 100644 be/src/olap/rowset/segment_v2/index_file_writer.cpp
create mode 100644 be/src/olap/rowset/segment_v2/index_file_writer.h
create mode 100644 be/src/olap/rowset/segment_v2/index_iterator.h
create mode 100644 be/src/olap/rowset/segment_v2/index_reader.h
create mode 100644 be/src/olap/rowset/segment_v2/index_storage_format.cpp
copy be/src/olap/rowset/segment_v2/{inverted_index_compaction.h =>
index_storage_format.h} (50%)
create mode 100644 be/src/olap/rowset/segment_v2/index_storage_format_v1.cpp
create mode 100644 be/src/olap/rowset/segment_v2/index_storage_format_v1.h
create mode 100644 be/src/olap/rowset/segment_v2/index_storage_format_v2.cpp
create mode 100644 be/src/olap/rowset/segment_v2/index_storage_format_v2.h
delete mode 100644 be/src/olap/rowset/segment_v2/inverted_index_file_writer.cpp
delete mode 100644 be/src/olap/rowset/segment_v2/inverted_index_file_writer.h
create mode 100644 be/src/olap/rowset/segment_v2/inverted_index_iterator.cpp
create mode 100644 be/src/olap/rowset/segment_v2/inverted_index_iterator.h
create mode 100644 be/src/util/jsonb_document.cpp
create mode 100644
be/src/vec/aggregate_functions/aggregate_function_foreachv2.cpp
delete mode 100644 be/src/vec/columns/column_set.h
rename be/src/vec/data_types/serde/{data_type_object_serde.cpp =>
data_type_variant_serde.cpp} (84%)
rename be/src/vec/data_types/serde/{data_type_object_serde.h =>
data_type_variant_serde.h} (100%)
create mode 100644 be/src/vec/exec/format/table/hive_reader.cpp
copy be/src/vec/exec/format/table/{hudi_reader.h => hive_reader.h} (75%)
create mode 100644 be/src/vec/functions/function_to_json.cpp
create mode 100644 be/test/cloud/cloud_meta_mgr_test.cpp
create mode 100644 be/test/io/cache/block_file_cache_test_common.h
create mode 100644 be/test/io/cache/block_file_cache_test_lru_dump.cpp
create mode 100644 be/test/io/cache/cache_lru_dumper_test.cpp
create mode 100644 be/test/io/cache/lru_queue_test.cpp
create mode 100644 be/test/util/profile_spec_test.cpp
rename be/test/vec/columns/{column_object_test.cpp => column_variant_test.cpp}
(81%)
create mode 100644
be/test/vec/data_types/serde/data_type_write_to_jsonb_test.cpp
delete mode 100644 be/test/vec/exec/format/paimon/paimon_schema_change_test.cpp
create mode 100644
be/test/vec/exec/format/text/hive_text_field_splitter_test.cpp
create mode 100644 be/test/vec/function/function_throw_exception_test.cpp
copy cloud/conf/{lsan_suppression.conf => asan_suppr.conf} (91%)
copy cloud/conf/{lsan_suppression.conf => lsan_suppr.conf} (96%)
copy cloud/conf/{lsan_suppression.conf => ubsan_suppr.conf} (91%)
create mode 100644 cloud/src/meta-service/meta_service_snapshot.cpp
create mode 100644 cloud/src/meta-store/CMakeLists.txt
create mode 100644 cloud/src/meta-store/blob_message.cpp
copy cloud/src/{common/util.h => meta-store/blob_message.h} (60%)
rename cloud/src/{meta-service => meta-store}/codec.cpp (87%)
rename cloud/src/{meta-service => meta-store}/codec.h (69%)
create mode 100644 cloud/src/meta-store/document_message.cpp
create mode 100644 cloud/src/meta-store/document_message.h
rename cloud/src/{meta-service => meta-store}/keys.cpp (61%)
rename cloud/src/{meta-service => meta-store}/keys.h (52%)
rename cloud/src/{meta-service => meta-store}/mem_txn_kv.cpp (63%)
rename cloud/src/{meta-service => meta-store}/mem_txn_kv.h (76%)
rename cloud/src/{meta-service => meta-store}/txn_kv.cpp (81%)
rename cloud/src/{meta-service => meta-store}/txn_kv.h (69%)
rename cloud/src/{meta-service => meta-store}/txn_kv_error.h (95%)
create mode 100644 cloud/src/meta-store/versionstamp.h
create mode 100644 cloud/test/document_message_test.cpp
create mode 100644 cloud/test/versionstamp_test.cpp
create mode 100644 conf/ubsan_ignorelist.txt
rename cloud/conf/lsan_suppression.conf => conf/ubsan_suppr.conf (91%)
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/data/regression/multi_delimit_serde/create_table.hql
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/dup_columns_table/bucket-0/data-72d4d52a-eca9-4542-a2af-cc17499731e6-0.parquet
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/dup_columns_table/manifest/manifest-5cae1365-d123-4172-9a89-4fbc02bee658-0
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/dup_columns_table/manifest/manifest-list-391058a9-952c-4aa9-892f-df3334e4109b-0
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/dup_columns_table/manifest/manifest-list-391058a9-952c-4aa9-892f-df3334e4109b-1
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/dup_columns_table/schema/schema-0
copy
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/{append_table =>
dup_columns_table}/snapshot/EARLIEST (100%)
copy
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/{all_table_with_parquet
=> dup_columns_table}/snapshot/LATEST (100%)
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/paimon1/db1.db/dup_columns_table/snapshot/snapshot-1
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/parquet/small_2rowgroup.parquet
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/create_preinstalled_scripts/iceberg/run16.sql
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/create_preinstalled_scripts/iceberg/run17.sql
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/create_preinstalled_scripts/paimon/run05.sql
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CreateRepositoryStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CreateTableAsSelectStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/DeleteStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/FromClause.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/InlineViewRef.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/InsertOverwriteTableStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/InsertStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/NativeInsertStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/QueryStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/SelectList.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/SelectListItem.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/SelectStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/SetOperationStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCacheHotSpotStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowColumnStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/StmtRewriter.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/TruncateTableStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/UpdateStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/WithClause.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/common/info/SimpleTableInfo.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/ExternalUtil.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/NameMapping.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/fileio/DelegateFileIO.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/fileio/DelegateInputFile.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/fileio/DelegateOutputFile.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/fileio/DelegateSeekableInputStream.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/ConnectorPropertiesUtils.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/ParamRules.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/PropertyUtils.java
rename
fe/fe-core/src/main/java/org/apache/doris/datasource/property/metastore/{AWSGlueProperties.java
=> AWSGlueMetaStoreBaseProperties.java} (50%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/metastore/AWSGlueMetaStoreProperties.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/metastore/AbstractHMSProperties.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/metastore/AliyunDLFBaseProperties.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/metastore/HMSAliyunDLFMetaStoreProperties.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/metastore/HMSGlueMetaStoreProperties.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/metastore/HMSPropertiesFactory.java
rename
fe/fe-core/src/main/java/org/apache/doris/{rewrite/mvrewrite/MVSelectFailedException.java
=> datasource/property/metastore/MetastorePropertiesFactory.java} (76%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/SchemaTypeMapper.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/DorisInput.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/DorisInputFile.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/DorisInputStream.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/DorisOutputFile.java
rename fe/fe-core/src/main/java/org/apache/doris/{analysis/InsertSource.java
=> fs/io/ParsedPath.java} (63%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/hdfs/HdfsInput.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/hdfs/HdfsInputFile.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/hdfs/HdfsInputStream.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/hdfs/HdfsOutputFile.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/io/hdfs/HdfsOutputStream.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadManagerAdapter.java
copy
fe/fe-core/src/main/java/org/apache/doris/{datasource/SchemaCacheValue.java =>
nereids/rules/analysis/CollectOneLevelRelation.java} (59%)
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/EliminateGroupByConstant.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/rules/JsonFunctionRewrite.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/DistinctWindowExpression.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/StatsDerive.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/mv/AbstractSelectMaterializedIndexRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/mv/SelectMaterializedIndexWithAggregate.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/mv/SelectMaterializedIndexWithoutAggregate.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/Cosec.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/Cot.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{JsonArray.java
=> JsonArrayIgnoreNull.java} (67%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/Sec.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/Time.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/ToJson.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/RestoreCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/StartTransactionCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/load/MysqlDataDescription.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/load/MysqlLoadCommand.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/MaterializedViewSelector.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/MysqlScanNode.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/TestExternalTableScanNode.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContextUtil.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/qe/cache/PartitionCache.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/BetweenToCompoundRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/CaseWhenToIf.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/CompoundPredicateWriteRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/ElementAtToSlotRefRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/EliminateUnnecessaryFunctions.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/EraseRedundantCastExpr.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/ExprRewriteRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/ExprRewriter.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/ExtractCommonFactorsRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/FoldConstantsRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/FunctionAlias.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/InferFiltersRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/MatchPredicateRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/NormalizeBinaryPredicatesRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/RewriteAliasFunctionRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/RewriteBinaryPredicatesRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/RewriteDateLiteralRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/RewriteEncryptKeyRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/RewriteFromUnixTimeRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/RewriteImplicitCastRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/RewriteInPredicateRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/RewriteIsNullIsNotNullRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/RoundLiteralInBinaryPredicatesRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/mvrewrite/CountDistinctToBitmap.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/mvrewrite/CountDistinctToBitmapOrHLLRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/mvrewrite/CountFieldToSum.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/mvrewrite/ExprToSlotRefRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/mvrewrite/FunctionCallEqualRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/mvrewrite/HLLHashToSlotRefRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/mvrewrite/MVExprEquivalent.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/mvrewrite/NDVToHll.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/mvrewrite/SlotRefEqualRule.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/rewrite/mvrewrite/ToBitmapToSlotRefRule.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/AggregateTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/BetweenPredicateTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/CreateMaterializedViewStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/CreateTableStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/DeleteStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/InsertArrayStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/InsertStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/OutFileClauseFunctionTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/QueryStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/SetOperationStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/SqlModeTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/TruncateTableTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/profile/ProfileStructureTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/paimon/PaimonExternalCatalogTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/ConnectorPropertiesUtilsTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/ParamRulesTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/PropertyPassThroughTest.java
rename
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/{AWSGluePropertiesTest.java
=> AWSGlueMetaStorePropertiesTest.java} (81%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/HMSGlueMetaStorePropertiesTest.java
rename
fe/fe-core/src/test/java/org/apache/doris/datasource/property/storage/{S3PropertyUtilsTest.java
=> S3ConnectorPropertiesUtilsTest.java} (99%)
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/tvf/FileTableValuedFunctionTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/fs/SchemaTypeMapperTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/load/DeleteHandlerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mysql/privilege/AuthTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/analysis/ExpressionAnalyzerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/analysis/SubqueryToApplyTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/mv/BaseMaterializedIndexSelectTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/mv/SelectMvIndexTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/mv/SelectRollupIndexTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/MysqlLoadCommandTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/RestoreCommandTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/MaterializedViewFunctionTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/MaterializedViewSelectorTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/SqlDigestTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/qe/LocalShuffleTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/rewrite/ExtractCommonFactorsRuleTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/rewrite/RewriteImplicitCastRuleTest.java
rename be/src/util/errno.h => gensrc/proto/file_cache.proto (54%)
create mode 100644 gensrc/thrift/ExternalTableSchema.thrift
create mode 100644
regression-test/data/correctness_p0/test_array_string_order_by.out
create mode 100644
regression-test/data/external_table_p0/hive/test_hive_case_sensibility.out
create mode 100644
regression-test/data/external_table_p0/hive/test_multi_delimit_serde.out
delete mode 100644
regression-test/data/external_table_p0/iceberg/test_iceberg_case_sensibility.out
create mode 100644
regression-test/data/external_table_p0/iceberg/test_iceberg_full_schema_change.out
create mode 100644
regression-test/data/external_table_p0/iceberg/test_iceberg_hadoop_case_sensibility.out
create mode 100644
regression-test/data/external_table_p0/iceberg/test_iceberg_hms_case_sensibility.out
create mode 100644
regression-test/data/external_table_p0/iceberg/test_iceberg_rest_case_sensibility.out
create mode 100644
regression-test/data/external_table_p0/paimon/test_paimon_full_schema_change.out
create mode 100644
regression-test/data/external_table_p2/hudi/test_hudi_full_schema_change.out
copy
regression-test/data/{query_p0/sql_functions/json_functions/test_mapagg_with_jsonfuncs.out
=> fault_injection_p0/cloud/test_cloud_mow_sc_inc_rowsets_dup.out} (60%)
create mode 100644 regression-test/data/jsonb_p0/test_json_to_json.out
copy
regression-test/data/{variant_github_events_new_p2/sql/issuesWithTheMostComments1.out
=> nereids_function_p0/agg_function/test_agg_case_sensitive.out} (69%)
create mode 100644
regression-test/data/nereids_p0/multi_distinct/multi_distinct_window.out
create mode 100644
regression-test/data/nereids_p0/runtime_filter/cte-runtime-filter.out
create mode 100644
regression-test/data/nereids_rules_p0/adjust_nullable/test_subquery_nullable.out
create mode 100644
regression-test/data/query_p0/schema_table/test_view_dependency.out
create mode 100644
regression-test/data/query_p0/sql_functions/datetime_functions/test_func_time.out
create mode 100644
regression-test/data/query_p0/sql_functions/math_functions/test_triangle.out
create mode 100644
regression-test/data/query_p0/sql_functions/string_functions/test_like_escape.out
create mode 100644
regression-test/data/query_p0/sql_functions/string_functions/test_like_literal.out
create mode 100644
regression-test/data/query_p0/sql_functions/string_functions/test_like_table.out
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/load.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/affinityByIssuesAndPRs1.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/affinityByIssuesAndPRs2.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/authorsWithTheMostPushes.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/countingStar1.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/countingStar2.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/countingStar3.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/distributionOfRepositoriesByStarCount.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/githubRoulette.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/howHasTheListOfTopRepositoriesChangedOverTheYears1.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/howHasTheListOfTopRepositoriesChangedOverTheYears2.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/howHasTheListOfTopRepositoriesChangedOverTheYears3.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/howHasTheListOfTopRepositoriesChangedOverTheYears4.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/howHasTheListOfTopRepositoriesChangedOverTheYears5.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/howHasTheListOfTopRepositoriesChangedOverTheYears6.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/howHasTheTotalNumberOfStarsChangedOverTime.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/issuesWithTheMostComments1.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/issuesWithTheMostComments2.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/issuesWithTheMostComments3.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/issuesWithTheMostComments4.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/issuesWithTheMostComments5.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/issuesWithTheMostComments6.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/issuesWithTheMostComments7.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/mostForkedRepositories.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/mostPopularCommentsOnGithub.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/organizationsByTheNumberOfRepositories.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/organizationsByTheNumberOfStars.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/proportionsBetweenStarsAndForks1.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/proportionsBetweenStarsAndForks2.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/proportionsBetweenStarsAndForks3.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/proportionsBetweenStarsAndForks4.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/proportionsBetweenStarsAndForks5.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesByAmountOfModifiedCode.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesByTheNumberOfPushes.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesWithClickhouse_related_comments1.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesWithClickhouse_related_comments2.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesWithDoris_related_comments1.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesWithDoris_related_comments2.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesWithTheHighestGrowthYoY.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesWithTheMaximumAmountOfIssues1.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesWithTheMaximumAmountOfIssues2.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesWithTheMaximumAmountOfIssues3.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesWithTheMaximumAmountOfIssues4.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesWithTheMaximumAmountOfPullRequests1.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesWithTheMaximumAmountOfPullRequests2.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesWithTheMaximumNumberOfAcceptedInvitations.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesWithTheMostPeopleWhoHavePushAccess1.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesWithTheMostStarsOverOneDay1.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesWithTheMostSteadyGrowthOverTime.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoriesWithTheWorstStagnation_order.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoryAffinityList1.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/repositoryAffinityList2.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/starsFromHeavyGithubUsers1.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/starsFromHeavyGithubUsers2.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/test_distinct_streaming_agg.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/theLongestRepositoryNames1.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/theLongestRepositoryNames2.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/theMostToughCodeReviews.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/theTotalNumberOfRepositoriesOnGithub.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/theTotalNumberOfUsersOnGithub1.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/theTotalNumberOfUsersOnGithub2.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/theTotalNumberOfUsersOnGithub3.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/theTotalNumberOfUsersOnGithub4.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/topRepositoriesByStars.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/whatIsTheBestDayOfTheWeekToCatchAStar.out
(100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/whoAreAllThosePeopleGivingStars1.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/whoAreAllThosePeopleGivingStars2.out (100%)
rename regression-test/data/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/sql/whoAreAllThosePeopleGivingStars3.out (100%)
create mode 100644 regression-test/data/variant_p0/escaped_chars.out
create mode 100644
regression-test/suites/cloud_p0/multi_cluster/test_change_node_net.groovy
create mode 100644
regression-test/suites/correctness_p0/test_array_string_order_by.groovy
create mode 100644 regression-test/suites/demo_p0/test_lru_persist.groovy
delete mode 100644
regression-test/suites/external_table_p0/hive/ddl/test_hive_database.groovy
create mode 100644
regression-test/suites/external_table_p0/hive/test_hive_case_sensibility.groovy
create mode 100644
regression-test/suites/external_table_p0/hive/test_multi_delimit_serde.groovy
delete mode 100644
regression-test/suites/external_table_p0/iceberg/test_iceberg_case_sensibility.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/test_iceberg_full_schema_change.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/test_iceberg_hadoop_case_sensibility.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/test_iceberg_hms_case_sensibility.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/test_iceberg_rest_case_sensibility.groovy
create mode 100644
regression-test/suites/external_table_p0/paimon/test_paimon_full_schema_change.groovy
create mode 100644
regression-test/suites/external_table_p2/hudi/test_hudi_full_schema_change.groovy
create mode 100644
regression-test/suites/fault_injection_p0/cloud/test_cloud_mow_sc_inc_rowsets_dup.groovy
create mode 100644 regression-test/suites/insert_p0/test_insert_timeout.groovy
create mode 100644 regression-test/suites/jsonb_p0/test_json_to_json.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_sink_tolerate.groovy
create mode 100644
regression-test/suites/nereids_function_p0/agg_function/test_agg_case_sensitive.groovy
create mode 100644
regression-test/suites/nereids_p0/expression/expression_depth_check.groovy
create mode 100644
regression-test/suites/nereids_p0/multi_distinct/multi_distinct_window.groovy
create mode 100644
regression-test/suites/nereids_p0/runtime_filter/cte-runtime-filter.groovy
rename
fe/fe-core/src/main/java/org/apache/doris/rewrite/mvrewrite/MVExprEqualRule.java
=>
regression-test/suites/nereids_p0/test_unsupported_start_transaction_command.groovy
(82%)
create mode 100644
regression-test/suites/nereids_rules_p0/adjust_nullable/test_subquery_nullable.groovy
create mode 100644
regression-test/suites/query_p0/schema_table/test_view_dependency.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/datetime_functions/test_func_time.groovy
rename be/src/util/errno.cpp =>
regression-test/suites/query_p0/sql_functions/math_functions/test_triangle.groovy
(50%)
create mode 100644
regression-test/suites/query_p0/sql_functions/string_functions/test_like_escape.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/string_functions/test_like_literal.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/string_functions/test_like_table.groovy
create mode 100644
regression-test/suites/schema_change_p0/test_unique_schema_key_change_multi_tablets.groovy
create mode 100644 regression-test/suites/statistics/test_hot_value.groovy
rename regression-test/suites/{variant_github_events_new_p2 =>
variant_github_events_new_p0}/load.groovy (93%)
create mode 100644 regression-test/suites/variant_p0/escaped_chars.groovy
create mode 100644 thirdparty/patches/thrift-0.16-fix_mutex_include.patch
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
