This is an automated email from the ASF dual-hosted git repository.
hellostephen pushed a change to branch hello-stephen-patch-2
in repository https://gitbox.apache.org/repos/asf/doris.git
from 71c545db5d4 [fix](ci) adjust thirdparth download url #48551
add 3030321e001 branch-3.0: [fix](build) Fix Mac compilation error caused
by namespace conflict in find_symbols.h #43004 (#49078)
add 3dfb51e57b7 branch-3.0: [opt](cache) enhance cache key computation by
removing comments and trimming SQL input #46099 (#46471)
add a58a92fbdba branch-3.0: [fix] Add initialization list to the copy
constructor of ScanPredicate in jni_connect.h #46666 (#46726)
add 6ad6d66dd5c [fix](Index)Make column unique ids in index dynamically
computed (#48988) (#49283)
add 8c6b1ab6bde branch-3.0: [fix](hudi) Set Hadoop Hudi Jni reader as
default #48602 (#48712)
add 8938f1d7de4 [feature](cloud) Support rename compute group sql (#46221)
(#48572)
add 8b6ec5aa237 branch-3.0: [fix](nereids)Fix dlog1, trim,
extract_url_parameter and parse_url FE constant calculate bug. #49074 (#49225)
add a1818fdc9dd branch-3.0: [fix](mow) remove rowset cache version #49295
(#49322)
add b4a0d427500 [improvement](statistics)Remove read lock when doing db
analyze. (#49250) (#49321)
add 09e5535effd Revert "branch-3.0: [fix](inverted index) fix wrong read
data for primary key #47841 (#48206)" (#49337)
add 16071a5ea35 branch-3.0: [fix](test) Force enable light schema change
for check before quit #49301 (#49339)
add fbf6c081eee branch-3.0: [feature](vault) Support database level
storage vault #45325 (#49305)
add 67de0c16504 branch-3.0: [fix](nereids) proper planning of shadow
columns for load and schema change concurrent execution #49332 (#49338)
add ea8d0d8c33e branch-3.0: [fix](hudi) replace non thread safe
SimpleDateFormat #48923 (#49021)
add 1f6c3839760 branch-3.0: [opt](paimon)Add suppressed information
display #48947 (#48996)
add 8d7541d384a branch-3.0: [fix](ob catalog) fix oceanbase catalog get
connection #48593 (#48807)
add cb2d720dbb1 [fix](ranger) make RangerDorisAccessController as
singleton to avoid more and more ranger policy refresher (#49352)
add 8fccc993fc1 branch-3.0: [fix](statistics)Fix replace table doesn't
remove table stat meta memory leak bug. #49345 (#49357)
add 05a1996760f branch-3.0: [Fix](cloud-mow) Fix dup key problem due to
calculating delete bitmaps for incremental rowsets based on wrong historical
rowsets during SC #49350 (#49364)
add 8beca26caeb branch-3.0: [opt](s3client) Set
ClientConfiguration.requestTimeoutMs default value from 3000ms to 30000ms
#49315 (#49363)
add 28c28043f2f branch-3.0: [feat](binlog) Add config to control whether
enable persistent connec… #48761 (#49006)
add b8990e10229 branch-3.0: [test](mtmv) Fix regression test not stable
and add log for debug #48483 (#49235)
add f4723a903f1 branch-3.0: [Improve](cloud) support caching
SchemaCloudDictionary in BE side #47629 (#48463)
add 0fafe1010f8 branch-3.0: [fix](fe) Fix non-master get image failed in
k8s #49072 (#49369)
add 7630b62e72f branch-3.0: [opt](meta-service) Implement set_value API
for meta-servce #49052 (#49359)
add bc37ec55c94 branch-3.0: [opt](cloud) Add config
enable_meta_service_endpoint_consistency_check #49264 (#49362)
add ab75d136895 branch-3.0: [Enhancement](compaction) Add tablet info when
cloud compaction crash #49296 (#49368)
add ec4171f553d branch-3.0: [fix](case) Rename
load_from_big_lateral_view.out to string_over_flow… #48243 (#49282)
add d471b0d385a [pick](profile) Pick profile related to 3.0 (#48717)
add 545910e1821 [compatibility](cold hot separation) Add a config to be
compatible with the previous behavior of HDFS resource if upgrading from v2.1
(#49400)
add f27be7aa13f branch-3.0: [fix](fragment) Remove unused instance ID
#49059 (#49076)
add 099722d36aa branch-3.0: [opt](filecache) Do not remove parent
directory when clear file cache #49199 (#49360)
add a298b786eb7 [improve](information schema) introduce routine load job
system table (#48963) (#49284)
add 745c466484a branch-3.0: [fix](function) fix the function elt #48701
(#48718)
add 01f86873788 branch-3.0: [fix](report) report queue size based on the
number of Bes and config #46190 (#47197)
add 9d659073a75 [cherry-pick](branch-3.0) Don't prematurely erase
DeleteRows in reading iceberg table with position delete (#47977) (#48309)
add 6c117fe5c2f branch-3.0 pick 49325 fix query statistics leak in BE
(#49401)
add fcdb79c2cc4 branch-3.0: [fix](core) fix subreplace when inputting a
large number of empty strings #49241 (#49302)
add c3e1fa5cd02 branch-3.0: [fix](restore) correct the storage_medium of
atomic restore #49330 (#49450)
add 8bbdb58903c branch-3.0: [Fix](log) correct tablet diff log in
`TabletInvertedIndex.tabletReport` #49390 (#49434)
add d06f9e03ea8 branch-3.0: [refactor](test) refactor compression test to
verify compatibility of ARM and X86 #49396 (#49432)
add 01277b402cc branch-3.0: [Fix](Compaction) atomic should not be
implicitly converted to int64_t #49427 (#49448)
add 3aba40553af branch-3.0: [Test](cbq) Record err and print at the end of
check_before_quit test #49406 (#49431)
add af2966067a6 [fix](group commit)Fix ut WalManagerTest (#49436)
add 98cd0ff5cc9 [fix](load) return DataQualityError when filtered rows
exceeds limit (#47617) (#49287)
add 7503d4de96c branch-3.0: [Fix](compaction) Fix full compaction error
when compaction size is too large #48958 (#49437)
add c089721fee9 [opt](cloud) Add config
enable_meta_service_endpoint_consistency_check (#49264) (#49361)
add a6e5395e52b branch-3.0: [fix](struct)Fixed the issue of inserting into
a struct type string literal with one more subfield causing BE coredump #49485
(#49552)
add 5d69536dab1 [fix](regression-test) Fix compaction trigger in
test_dup_keys_schema_change and test_uniq_keys_schema_change (#49544)
add bafa8d460ff branch-3.0: [fix](cloud) fix misuse of
file_cache_evict_in_advance_batch_bytes #49336 (#49495)
add b1368fdccb6 branch-3.0: [Bug] Fix accidental table deletion during
restore job #48820 (#49496)
add 7e8c81d1983 branch-3.0: [Opt](cloud-sc) Clear stop token when
`commit_tablet_job` fails #49275 (#49494)
add f55665f529f branch-3.0: [case](restore) Rename repo name of
backup-restore regression cases with suite name (#49533)
add 58c1dd81451 [chore](information schema) make version of
SCH_ROUTINE_LOAD_JOB consistent with the master (#49558)
add fb54f1e5cd5 branch-3.0: [enhancement](cloud) set the connection
timeout and request timeout for FE requests to the meta service #49546 (#49557)
add 5511b92972e branch-3.0: [enhancement](compaction) generate multiple
compaction tasks each round #49547 (#49563)
add b5232d2bc95 branch-3.0: [fix](Nereids) fold str_to_date to wrong
result when parameter out range #49033 (#49151)
add 48794936d37 branch-3.0: [fix](Nereids) fold constant for string
function process emoji character by mistake #49087 (#49346)
add 785fb1a0d85 branch-3.0: [fix](nereids) project child output to union
output in correct order after eliminate empty relation #49257 (#49463)
add 0be4d2b3cab branch-3.0: [fix](tracker) Missing attaching task in fold
constant executor #49405 (#49423)
add 03cd5f5b294 branch-3.0: [opt](metrics) optimize performance of metrics
endpoint #49380 (#49454)
add c780f2e5d18 branch-3.0: [fix](jdbc catalog) ensure initialization
before fetching row count #49442 (#49475)
add 3f1634c2f44 branch-3.0: [fix](Nereids) fix double literal to string
literal cast problem #49416 (#49522)
add 80fe049c827 branch-3.0: [chore](task) log the thrift message size if
the broken pipe is occurred #49492 (#49507)
add 7dbe08377b1 [improve](schema-change) support nested type with varchar
type to support length growing (#48025)
add 499db7ad91f branch-3.0: [Fix](GA)Remove extra blank lines to avoid
parsing failures #49615 (#49617)
add 123f55d82ba branch-3.0: [fix](cloud) retry read_at when corruption
using file cache #48786 (#49640)
add 7bf370597dd [fix](schema-change) Nested types should only support
enlarging varchar length with light schema change (#49452) (#49592)
add e5d55107a11 branch-3.0: [Opt](bvar) Add bvar for txn tablet map #49567
(#49626)
add 4b3bc4b8035 branch-3.0: [chore](metrics) Add agent batch task metrics
#49480 (#49506)
add 1f87cfc5aea branch-3.0: correct
`DeleteBitmap::get_delete_bitmap_count` (#49629)
add 86e96f52cd7 branch-3.0: [Fix](txn) Remove `TabletTxnInfo` if version
exists when publish version #49564 (#49588)
add b7de2cdeed5 branch-3.0: [fix](catalog)when checkpoint,use
cacheThreadPool #49097 (#49517)
add 5e42583d0d1 branch-3.0: [fix](backup) Save snapshot meta during replay
#49550 (#49605)
add d5544ca247b branch-3.0: [fix](auth)Delete from should not check
select_priv #49239 (#49620)
add eb470282090 branch-3.0: [fix](mow) remove agg cache version for unused
rowsets #49511 (#49578)
add 02ea353ab1a branch-3.0: [fix](fe) Using `try-with-resource` for auto
close `RemoteFileSystem` #49637 (#49651)
add 45d034dde9d branch-3.0: [fix](binlog) get table with db lock if the
table not exists #49566 (#49647)
add cfa6ce0289c branch-3.0: [fix](auth)Prohibit other users from modifying
the root #48752 (#49584)
add 0c5c400b327 branch-3.0: [feature](cloud)Impl file cache microbench
#47563 (#49440)
add d85816a4a6a branch-3.0: [fix](variant) update least common type in
ColumnObject::pop_back #48935 (#48978)
add 0c3e73e6016 Branch-3.0 [Fix](RowStore) fix partial columns as row
store (#49542) (#49609)
add e26bac2d2e4 branch-3.0: [fix](Nereids) use StringLikeLiteral as
parameter type in constant folding #49413 (#49446)
add 0e33923c3f0 branch-3.0: [fix](Nereids) fix initcap fe fold constant
#49061 (#49583)
add 11ce43f1faa branch-3.0: [Feature](function) support year of week
#48870 (#49011)
add 346c88a86fc branch-3.0: [fix](thrift) Pick THRIFT-5492: Add readEnd to
TBufferedTransport #49649 (#49655)
add 85c82072375 branch-3.0: [function](date) Support date trunc function
#49540 (#49660)
add 09a7a355478 [fix] (streamload) fixed the issue of data loss due to
concurrency when importing data from streamload (#48948) (#49666)
add ad4dd621cfe [chore](information schema) rename routine_load_job system
table to routine_load_jobs (#49515) (#49663)
add 086d09f70e8 branch-3.0: [fix](cloud) fix corner case when warm up data
larger than cache capacity #49050 (#49675)
add 1abfa4f270f [Bug](materialized-view) check duplicate expr when create
mv stmt not have groupby exprs (#49595)
add 2acf0938183 branch-3.0: [fix](load) Fix the issue of insert into
select concurrent reporting causing no error url #49669 (#49687)
add 29b4f4ee15c branch-3.0: [opt](connection) add connection num in error
msg #49471 (#49599)
add d5f639d401e branch-3.0: [enhancement](compaction) replace hardcoded
compaction thresholds with config #49662 (#49681)
add 280aba1fde6 [Fix](case) Fix cold data compaction fault injection case
(#49702)
add 367d4e416c0 [improve](cloud-mow) Make mow stream load retry times more
reasonable (#49089)
add 2683e5b78a1 branch-3.0: [Fix](Compaction) Cumulative Points Not
Incrementing After Delete Operation #47282 (#49732)
add ca9ebecd0d4 branch-3.0: [fix](inverted index) Clear inverted index
cache from file cache #49685 (#49738)
add 41830958540 branch-3.0: [fix](test) Complete the missing db name in
check_before_quit test #49674 (#49726)
add 494d78b0481 branch-3.0: [improve](thrift) Config
thrift_max_message_size for FE SIMPLE and TH… #49678 (#49723)
add bf6923696de branch-3.0: [improve](thrift) Config
thrift_max_message_size for THREAD_POOL and … #49677 (#49722)
add ebfcbfd25d8 branch-3.0: [fix](lock) Fix ~VDataStreamMgr lock
_receiver_map #48057 (#49747)
add 49a8b75493c branch-3.0: [Bug](udf) should delete local ref when return
error msg #48609 (#49527)
add 054ef7a1b80 [Fix]fix report query statistics to FE cores (#49711)
add 2c927224acc branch-3.0: [opt](identifer) let unicode format as a
superset of latin format #48078 (#49808)
add d9081b219bd branch-3.0: [improve](restore) Link existing rowset files
bidirectionally#49233 (#49788)
add c1aed981042 branch-3.0: [fix](mtmv) Fix collecting mv candidates when
dml controlled by enable_dml_materialized_view_rewrite switch #48374 (#49261)
add 0983526722a branch-3.0-pick: [Fix](cloud-mow) Check partition's
version to avoid wrongly update visible versions' delete bitmaps (#49710)
(#49796)
add 173eaad5774 branch-3.0: [fix](test) Adapta case to multi FE node test
#49764 (#49785)
add a733a1ec2e8 branch-3.0: [case](mtmv)add case for insert overwrite of
mtmv force drop partition #48946 (#49799)
add a90684ee322 [fix](columns) fix bug found by UT and add regression test
(#48554) (#48854)
add 413552cabbd [feature](function) upper lower support utf8 input
(#49763)
add d5288985ca7 branch-3.0: [fix](auth)Ignore replay edit log error of
auth #49348 (#49786)
add a7ab7678543 branch-3.0: [fix](jdbc catalog) Fix connection leak in
PostgreSQL JDBC client #49568 (#49760)
add 654e1e517c1 branch-3.0: [chore](log) Fix typo when meta-service checks
priority_networks #49704 (#49827)
add 99c6e1f0a83 branch-3.0: [fix](nereids)avoid generate Runtime filter
whose target is not a base table column #48804 (#49310)
add 9ad7d6d7b03 branch-3.0: [Bug][function] fix the string cast jsonb
cause null map have not init value #49810 (#49816)
add b4d9c47f8e6 branch-3.0: [chore](log) Standardize S3 failure log
formats to enable critical operation monitoring #49813 (#49828)
add 64cfdf71e06 branch-3.0: [fix](gson) Missing the serialization of the
partition's storage policy #49721 (#49840)
add 51c2ebe5d87 branch-3.0: [fix](microbench) Fix some file cache
microbench compile bug #49269 (#49720)
add be6bb47148e branch-3.0: [enhancement](case) add cases for mow table
load empty file #49843 (#49857)
add c7c9de3e953 branch-3.0: [fix](cloud) fix get_or_set emptry <offset,
cell> map #49793 (#49873)
add 1eb1328fd2c branch-3.0: [chore](log) change PointQueryExecutor log to
VLOG_DEBUG #49860 (#49868)
add 2693061e9ca [fix](function) wrong result of arrays_overlap (#49403)
(#49697)
add e4f5f18ef4e branch-3.0: [fix](function) check return type is nullptr
in FunctionBasePtr::build #49737 (#49762)
add 7c5f48486a7 Fix thrift core in asan mode (#49819)
add 62bfeac5055 branch-3.0: [fix](variant) building index on the variant
column is prohibited #49159 (#49844)
add 75618c3e1b5 [regression-test](cases) un-drop table after tests (#49879)
add d2cae4d21bf [fix] (inverted index) Disallow variant columns from using
inverted index format v1 (#49823) (#49890)
add 414f8a94581 [regression-test](framework) add multi cluster result
compare on cloud mode. (#49735)
add 89ce038c6b1 [fix](config) Turn on default value of
`enable_cloud_tablet_report` (#49757)
add 60df072fa4c branch-3.0: [fix](cloud-schema-change) Remove schema
change job even if alter version < 2 #49062 (#49921)
add 3de3682a9fd branch-3.0: [Fix](full compaction) Fix problems for full
compaction #49825 (#49917)
add d1845d381cc Merge branch 'branch-3.0' into hello-stephen-patch-2
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 80 +-
be/CMakeLists.txt | 11 +
be/cmake/thirdparty.cmake | 4 +
be/src/agent/heartbeat_server.cpp | 9 +-
be/src/agent/task_worker_pool.cpp | 7 +-
be/src/cloud/cloud_cumulative_compaction.cpp | 1 +
.../cloud/cloud_cumulative_compaction_policy.cpp | 7 +-
.../cloud/cloud_engine_calc_delete_bitmap_task.cpp | 3 +-
be/src/cloud/cloud_full_compaction.cpp | 26 +-
be/src/cloud/cloud_full_compaction.h | 4 +-
be/src/cloud/cloud_meta_mgr.cpp | 89 +-
be/src/cloud/cloud_meta_mgr.h | 7 +-
be/src/cloud/cloud_schema_change_job.cpp | 24 +-
be/src/cloud/cloud_storage_engine.cpp | 24 +-
be/src/cloud/cloud_storage_engine.h | 7 +-
be/src/cloud/cloud_tablet.cpp | 12 +-
be/src/cloud/cloud_tablet.h | 5 +-
be/src/cloud/config.cpp | 6 +-
be/src/cloud/config.h | 4 +-
be/src/cloud/injection_point_action.cpp | 22 +
be/src/cloud/schema_cloud_dictionary_cache.cpp | 226 ++
be/src/cloud/schema_cloud_dictionary_cache.h | 101 +
be/src/common/config.cpp | 17 +-
be/src/common/config.h | 18 +-
be/src/exec/schema_scanner.cpp | 3 +
be/src/exec/schema_scanner/schema_helper.cpp | 9 +
be/src/exec/schema_scanner/schema_helper.h | 6 +
.../schema_routine_load_job_scanner.cpp | 199 ++
.../schema_routine_load_job_scanner.h | 62 +-
be/src/io/cache/block_file_cache.cpp | 104 +-
be/src/io/cache/fs_file_cache_storage.cpp | 42 +-
be/src/io/fs/hdfs_file_system.cpp | 3 +-
be/src/io/fs/s3_file_reader.cpp | 16 +-
be/src/io/fs/s3_file_system.cpp | 2 +-
be/src/io/fs/s3_file_writer.cpp | 15 +-
be/src/io/tools/CMakeLists.txt | 68 +
{gensrc => be/src/io/tools}/Makefile | 0
be/src/io/tools/file_cache_microbench.cpp | 2361 ++++++++++++++++++++
be/src/io/tools/proto/Makefile | 38 +
.../src/io/tools/proto/microbench.proto | 47 +-
be/src/io/tools/readme.md | 133 ++
be/src/olap/base_compaction.cpp | 2 +-
be/src/olap/base_tablet.cpp | 3 +-
be/src/olap/base_tablet.h | 4 +-
be/src/olap/compaction_permit_limiter.h | 2 +-
be/src/olap/full_compaction.cpp | 105 +-
be/src/olap/full_compaction.h | 5 +-
be/src/olap/olap_server.cpp | 3 +-
be/src/olap/rowset/rowset.cpp | 29 +
be/src/olap/rowset/rowset.h | 2 +
be/src/olap/rowset/segment_v2/column_reader.cpp | 23 +-
.../rowset/segment_v2/indexed_column_reader.cpp | 25 +-
.../olap/rowset/segment_v2/inverted_index_desc.cpp | 13 +
.../olap/rowset/segment_v2/inverted_index_desc.h | 5 +
.../olap/rowset/segment_v2/ordinal_page_index.cpp | 22 +-
be/src/olap/rowset/segment_v2/page_io.cpp | 67 +
be/src/olap/rowset/segment_v2/page_io.h | 34 +-
be/src/olap/rowset/segment_v2/segment.cpp | 30 +-
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 14 +-
be/src/olap/storage_engine.cpp | 6 +
be/src/olap/tablet.cpp | 22 +-
be/src/olap/tablet.h | 3 +-
be/src/olap/tablet_manager.cpp | 2 +-
be/src/olap/tablet_meta.cpp | 112 +-
be/src/olap/tablet_meta.h | 9 +-
be/src/olap/task/engine_publish_version_task.cpp | 3 +
be/src/olap/txn_manager.cpp | 39 +-
be/src/olap/txn_manager.h | 8 +
be/src/olap/wal/wal_manager.cpp | 4 +
.../exec/group_commit_block_sink_operator.cpp | 14 +-
be/src/pipeline/exec/operator.cpp | 2 -
be/src/pipeline/pipeline_fragment_context.cpp | 49 +-
be/src/pipeline/pipeline_fragment_context.h | 4 +-
be/src/runtime/fold_constant_executor.cpp | 2 +-
be/src/runtime/fragment_mgr.cpp | 85 +-
be/src/runtime/memory/cache_policy.h | 9 +-
be/src/runtime/query_context.cpp | 18 +-
be/src/runtime/query_context.h | 11 +-
be/src/runtime/runtime_query_statistics_mgr.cpp | 124 +-
be/src/runtime/runtime_state.cpp | 18 +-
be/src/runtime/runtime_state.h | 2 +-
be/src/runtime/snapshot_loader.cpp | 94 +-
be/src/runtime/snapshot_loader.h | 7 +
be/src/service/backend_service.cpp | 33 +-
be/src/service/point_query_executor.cpp | 2 +
be/src/service/point_query_executor.h | 6 +-
be/src/util/runtime_profile.cpp | 7 +-
be/src/util/runtime_profile.h | 12 -
be/src/util/s3_util.cpp | 2 +
be/src/util/thrift_server.cpp | 27 +-
.../aggregate_function_java_udaf.h | 13 +-
be/src/vec/columns/column_decimal.cpp | 10 +-
be/src/vec/columns/column_object.cpp | 3 +
be/src/vec/columns/column_string.cpp | 33 +-
be/src/vec/columns/column_string.h | 1 +
be/src/vec/columns/columns_number.h | 1 -
be/src/vec/core/field.cpp | 6 +-
.../data_types/serde/data_type_decimal_serde.cpp | 2 +-
.../data_types/serde/data_type_struct_serde.cpp | 6 +-
be/src/vec/exec/format/csv/csv_reader.cpp | 21 +-
be/src/vec/exec/format/json/new_json_reader.cpp | 57 +-
be/src/vec/exec/format/table/hudi_jni_reader.cpp | 10 +-
be/src/vec/exec/format/table/iceberg_reader.cpp | 8 +-
be/src/vec/exec/jni_connector.h | 6 +-
be/src/vec/exec/scan/vfile_scanner.cpp | 12 +-
.../exprs/table_function/udf_table_function.cpp | 7 +-
.../vec/functions/array/function_array_cum_sum.cpp | 10 +-
.../functions/array/function_array_difference.h | 8 +-
.../vec/functions/array/function_array_element.h | 6 +-
.../array/function_array_enumerate_uniq.cpp | 1 -
.../vec/functions/array/function_arrays_overlap.h | 87 +-
be/src/vec/functions/date_time_transforms.h | 17 +-
be/src/vec/functions/function.h | 8 +
be/src/vec/functions/function_cast.h | 12 +-
be/src/vec/functions/function_java_udf.cpp | 3 +-
be/src/vec/functions/function_string.cpp | 62 +-
be/src/vec/functions/function_string.h | 6 +-
be/src/vec/functions/function_timestamp.cpp | 51 +-
be/src/vec/functions/to_time_function.cpp | 10 +-
be/src/vec/functions/url/find_symbols.h | 56 +-
be/src/vec/olap/vertical_merge_iterator.cpp | 2 +
be/src/vec/runtime/vdata_stream_mgr.cpp | 15 +-
be/src/vec/runtime/vdatetime_value.cpp | 26 +
be/src/vec/runtime/vdatetime_value.h | 1 +
be/src/vec/sink/vrow_distribution.cpp | 18 +-
be/src/vec/sink/vtablet_block_convertor.cpp | 47 +-
be/src/vec/sink/vtablet_block_convertor.h | 13 +-
be/src/vec/sink/vtablet_finder.cpp | 16 +-
be/src/vec/sink/vtablet_finder.h | 4 +-
be/src/vec/sink/writer/async_result_writer.cpp | 54 +-
.../cloud_cumulative_compaction_policy_test.cpp | 148 ++
.../cloud/test_schema_cloud_dictionary_cache.cpp | 178 ++
be/test/io/cache/block_file_cache_test.cpp | 216 +-
be/test/olap/compaction_permit_limiter_test.cpp | 78 +
be/test/olap/rowset/beta_rowset_test.cpp | 107 +
be/test/runtime/snapshot_loader_test.cpp | 125 +-
be/test/vec/columns/column_object_test.cpp | 130 ++
.../vec/function/function_arrays_overlap_test.cpp | 63 +-
be/test/vec/function/function_string_test.cpp | 18 +-
be/test/vec/function/function_sub_replace_test.cpp | 51 +
be/test/vec/function/function_test_util.cpp | 3 +
be/test/vec/function/function_time_test.cpp | 12 +
.../vec/function/simple_function_factory_test.cpp | 98 +
build.sh | 96 +-
cloud/src/common/bvars.cpp | 2 +-
cloud/src/common/bvars.h | 1 +
cloud/src/common/network_util.cpp | 2 +-
cloud/src/common/util.cpp | 24 +
cloud/src/common/util.h | 6 +
cloud/src/meta-service/http_encode_key.cpp | 208 +-
cloud/src/meta-service/meta_service.cpp | 169 +-
cloud/src/meta-service/meta_service.h | 10 +
cloud/src/meta-service/meta_service_http.cpp | 16 +-
cloud/src/meta-service/meta_service_http.h | 3 +
cloud/src/meta-service/meta_service_job.cpp | 5 +-
cloud/src/meta-service/meta_service_resource.cpp | 12 +-
cloud/src/meta-service/meta_service_schema.cpp | 6 +-
cloud/src/meta-service/meta_service_txn.cpp | 1 +
cloud/src/resource-manager/resource_manager.cpp | 30 +-
cloud/src/resource-manager/resource_manager.h | 4 +-
cloud/test/meta_service_http_test.cpp | 73 +
cloud/test/meta_service_test.cpp | 384 +++-
cloud/test/mock_resource_manager.h | 4 +-
dist/LICENSE-dist.txt | 1 +
dist/licenses/LICENSE-icu.txt | 542 +++++
.../main/java/org/apache/doris/common/Config.java | 16 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 1 +
.../main/java/org/apache/doris/alter/Alter.java | 1 +
.../apache/doris/alter/SchemaChangeHandler.java | 46 +-
.../apache/doris/analysis/AlterRepositoryStmt.java | 2 +-
.../org/apache/doris/analysis/AlterUserStmt.java | 8 +
.../apache/doris/analysis/BuildIndexClause.java | 2 +-
.../apache/doris/analysis/CreateIndexClause.java | 2 +-
.../doris/analysis/CreateMaterializedViewStmt.java | 21 +-
.../doris/analysis/CreateRepositoryStmt.java | 2 +-
.../org/apache/doris/analysis/CreateTableStmt.java | 15 +-
.../apache/doris/analysis/FunctionCallExpr.java | 2 +-
.../java/org/apache/doris/analysis/IndexDef.java | 19 +-
.../org/apache/doris/analysis/SchemaTableType.java | 4 +-
.../java/org/apache/doris/backup/BackupJob.java | 12 +-
.../java/org/apache/doris/backup/RestoreJob.java | 26 +-
.../doris/catalog/BuiltinScalarFunctions.java | 14 +-
.../main/java/org/apache/doris/catalog/Column.java | 17 +-
.../java/org/apache/doris/catalog/ColumnType.java | 72 +
.../java/org/apache/doris/catalog/Database.java | 24 +
.../main/java/org/apache/doris/catalog/Env.java | 2 +-
.../main/java/org/apache/doris/catalog/Index.java | 40 +-
.../doris/catalog/MaterializedIndexMeta.java | 7 -
.../org/apache/doris/catalog/PartitionInfo.java | 1 +
.../java/org/apache/doris/catalog/SchemaTable.java | 24 +
.../org/apache/doris/catalog/TableProperty.java | 3 +
.../apache/doris/catalog/TabletInvertedIndex.java | 20 +-
.../ranger/doris/RangerDorisAccessController.java | 19 +-
.../apache/doris/cloud/CacheHotspotManager.java | 83 +-
.../doris/cloud/catalog/CloudClusterChecker.java | 18 +-
.../org/apache/doris/cloud/catalog/CloudEnv.java | 4 +
.../cloud/datasource/CloudInternalCatalog.java | 5 +-
.../apache/doris/cloud/rpc/MetaServiceClient.java | 204 +-
.../apache/doris/cloud/rpc/MetaServiceProxy.java | 12 +-
.../doris/cloud/system/CloudSystemInfoService.java | 65 +-
.../java/org/apache/doris/common/FeNameFormat.java | 23 +-
.../java/org/apache/doris/common/ThriftServer.java | 51 +-
.../apache/doris/common/proc/BackendsProcDir.java | 2 +-
.../common/proc/CurrentQueryInfoProvider.java | 4 +-
.../doris/common/{util => profile}/AggCounter.java | 2 +-
.../doris/common/{util => profile}/Counter.java | 2 +-
.../doris/common/profile/ExecutionProfile.java | 66 +-
.../org/apache/doris/common/profile/Profile.java | 341 ++-
.../doris/common/profile/ProfileManager.java | 325 ++-
.../common/{util => profile}/RuntimeProfile.java | 55 +-
.../doris/common/profile/SummaryProfile.java | 5 +-
.../org/apache/doris/common/util/BrokerUtil.java | 20 +-
.../apache/doris/common/util/PropertyAnalyzer.java | 53 +-
.../java/org/apache/doris/common/util/Util.java | 20 +
.../doris/datasource/ExternalMetaCacheMgr.java | 25 +-
.../apache/doris/datasource/InternalCatalog.java | 3 +-
.../apache/doris/datasource/hudi/HudiUtils.java | 8 +-
.../doris/datasource/jdbc/JdbcExternalTable.java | 1 +
.../jdbc/client/JdbcOceanBaseClient.java | 8 +-
.../jdbc/client/JdbcPostgreSQLClient.java | 26 +-
.../org/apache/doris/httpv2/meta/MetaService.java | 13 +-
.../apache/doris/load/loadv2/BrokerLoadJob.java | 2 +-
.../load/routineload/KafkaRoutineLoadJob.java | 12 +-
.../doris/load/routineload/RoutineLoadJob.java | 63 +-
.../doris/load/routineload/RoutineLoadManager.java | 4 +
.../load/routineload/RoutineLoadProgress.java | 2 +-
.../load/routineload/RoutineLoadStatistic.java | 1 +
.../org/apache/doris/master/ReportHandler.java | 16 +-
.../java/org/apache/doris/metric/MetricRepo.java | 13 +
.../org/apache/doris/monitor/jvm/JvmService.java | 6 +-
.../org/apache/doris/monitor/jvm/JvmStats.java | 42 +-
.../org/apache/doris/mtmv/MTMVPartitionUtil.java | 6 +
.../org/apache/doris/mysql/AcceptListener.java | 11 +-
.../mysql/privilege/AccessControllerManager.java | 2 +-
.../org/apache/doris/mysql/privilege/Auth.java | 16 +-
.../org/apache/doris/nereids/CascadesContext.java | 6 +-
.../org/apache/doris/nereids/SqlCacheContext.java | 3 +-
.../org/apache/doris/nereids/StatementContext.java | 5 +-
.../doris/nereids/jobs/executor/Analyzer.java | 2 -
...or.java => TableCollectAndHookInitializer.java} | 8 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 7 +
.../post/RuntimeFilterPushDownVisitor.java | 21 +-
.../org/apache/doris/nereids/rules/RuleType.java | 1 +
.../rules/analysis/AddInitMaterializationHook.java | 15 +-
.../doris/nereids/rules/analysis/BindSink.java | 13 +
.../nereids/rules/analysis/CollectRelation.java | 12 +-
.../mv/AbstractMaterializedViewRule.java | 11 +
.../rules/rewrite/EliminateEmptyRelation.java | 22 +-
.../doris/nereids/stats/ExpressionEstimation.java | 16 +
.../executable/DateTimeExtractAndTransform.java | 46 +-
.../functions/executable/NumericArithmetic.java | 11 -
.../functions/executable/StringArithmetic.java | 197 +-
.../expressions/functions/scalar/DateTrunc.java | 85 +-
.../expressions/functions/scalar/StrLeft.java | 70 -
.../expressions/functions/scalar/StrRight.java | 70 -
.../scalar/{Dlog1.java => YearOfWeek.java} | 42 +-
.../nereids/trees/expressions/literal/Literal.java | 25 +
.../expressions/visitor/ScalarFunctionVisitor.java | 20 +-
.../apache/doris/nereids/trees/plans/PlanType.java | 3 +-
.../AlterSystemRenameComputeGroupCommand.java | 85 +
.../trees/plans/commands/DeleteFromCommand.java | 9 +-
.../nereids/trees/plans/commands/LoadCommand.java | 3 +-
.../trees/plans/commands/info/CreateTableInfo.java | 9 +-
.../trees/plans/commands/info/IndexDefinition.java | 17 +-
.../org/apache/doris/nereids/util/DateUtils.java | 6 +-
.../org/apache/doris/planner/OlapScanNode.java | 2 +-
.../org/apache/doris/planner/OlapTableSink.java | 2 +-
.../java/org/apache/doris/qe/ConnectScheduler.java | 14 +-
.../java/org/apache/doris/qe/QeProcessorImpl.java | 57 +-
.../org/apache/doris/qe/QueryStatisticsItem.java | 2 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 10 +-
.../apache/doris/service/FrontendServiceImpl.java | 71 +
.../sessions/FlightSessionsWithTokenManager.java | 20 +-
.../apache/doris/statistics/AnalysisManager.java | 51 +-
.../apache/doris/statistics/StatisticsCleaner.java | 19 +-
.../java/org/apache/doris/task/AgentBatchTask.java | 22 +-
.../apache/doris/task/AlterInvertedIndexTask.java | 4 +-
.../org/apache/doris/task/CreateReplicaTask.java | 2 +-
.../org/apache/doris/analysis/IndexDefTest.java | 5 +-
.../java/org/apache/doris/catalog/IndexTest.java | 164 ++
.../org/apache/doris/catalog/OlapTableTest.java | 2 +-
.../doris/cloud/cache/CacheHotspotManagerTest.java | 124 +
.../org/apache/doris/common/FeNameFormatTest.java | 110 +-
.../doris/common/proc/IndexesProcNodeTest.java | 8 +-
.../doris/common/profile/AutoProfileTest.java | 79 +
.../doris/common/profile/ProfileManagerTest.java | 848 +++++++
.../common/profile/ProfilePersistentTest.java | 541 +++++
.../common/profile/RuntimeProfileMergeTest.java | 298 +++
.../{util => profile}/RuntimeProfileTest.java | 20 +-
.../doris/common/util/ProfilePersistentTest.java | 314 ---
.../org/apache/doris/common/util/UtilTest.java | 86 +
.../doris/datasource/hudi/HudiUtilsTest.java | 97 +
.../nereids/postprocess/RuntimeFilterTest.java | 76 +
.../nereids/rules/expression/FoldConstantTest.java | 126 ++
.../rules/rewrite/EliminateEmptyRelationTest.java | 92 +
.../trees/plans/commands/IndexDefinitionTest.java | 12 +-
.../persist/TableAddOrDropColumnsInfoTest.java | 2 +-
.../java/org/apache/doris/task/AgentTaskTest.java | 2 +
gensrc/proto/cloud.proto | 22 +
gensrc/thrift/Descriptors.thrift | 2 +
gensrc/thrift/FrontendService.thrift | 32 +
gensrc/thrift/RuntimeProfile.thrift | 3 +-
.../data/compression_p0/{load.out => query.out} | Bin 2093 -> 2425 bytes
.../cloud/test_cloud_full_compaction_mow.out} | Bin 107 -> 150 bytes
.../cloud/test_cloud_mow_new_tablet_compaction.out | Bin 206 -> 206 bytes
...> test_cloud_sc_self_retry_with_stop_token.out} | Bin 206 -> 167 bytes
.../test_first_delete_compaction.out} | Bin 107 -> 115 bytes
...compaction.out => test_full_compaction_mow.out} | Bin 206 -> 181 bytes
.../data/insert_p0/test_struct_insert.out | Bin 625 -> 4698 bytes
.../test_array_contains_with_inverted_index.out | Bin 43652 -> 10664 bytes
.../stream_load/test_stream_load_empty_file.out | Bin 107 -> 120 bytes
.../testSelectMVWithTableAlias.out | Bin 186 -> 220 bytes
regression-test/data/point_query_p0/load.out | Bin 5193 -> 5239 bytes
regression-test/data/query_p0/sort/heap_sort.csv | 7 +
.../sort/heap_sort.out} | Bin 186 -> 193 bytes
.../array_functions/test_array_functions.out | Bin 28026 -> 28028 bytes
.../test_array_functions_by_literal.out | Bin 29819 -> 29825 bytes
.../datetime_functions/test_date_function.out | Bin 10292 -> 10699 bytes
.../datetime_functions/test_date_trunc.out | Bin 5294 -> 9785 bytes
.../json_functions/test_json_function.out | Bin 1260 -> 1295 bytes
.../string_functions/test_string_function.out | Bin 4892 -> 4890 bytes
...m_big_lateral_view.out => string_over_flow.out} | Bin
.../schema_change_p0/test_type_length_change.out | Bin 0 -> 362 bytes
.../test_varchar_sc_in_complex.out | Bin 0 -> 14064 bytes
regression-test/data/variant_p0/rqg/rqg6.out | Bin 0 -> 236 bytes
.../test_array_contains_with_inverted_index.out | Bin 45214 -> 46174 bytes
.../org/apache/doris/regression/Config.groovy | 10 +
.../apache/doris/regression/ConfigOptions.groovy | 10 +
.../org/apache/doris/regression/suite/Suite.groovy | 20 +-
.../pipeline/cloud_p0/conf/be_custom.conf | 1 +
.../pipeline/cloud_p0/conf/fe_custom.conf | 5 +-
regression-test/pipeline/p0/conf/be.conf | 2 +-
regression-test/pipeline/p0/conf/fe.conf | 4 +
.../plugins/plugin_multi_cluster.groovy | 148 ++
.../test_root_user.groovy} | 49 +-
.../alter_p2/test_alter_table_property.groovy | 2 -
.../auth_call/test_dml_delete_table_auth.groovy | 9 -
.../backup_restore/test_backup_cancelled.groovy | 2 +-
.../backup_restore/test_backup_restore.groovy | 2 +-
.../test_backup_restore_alias.groovy | 3 +-
.../test_backup_restore_atomic.groovy | 2 +-
.../test_backup_restore_atomic_cancel.groovy | 2 +-
.../test_backup_restore_atomic_with_alter.groovy | 2 +-
.../test_backup_restore_atomic_with_view.groovy | 2 +-
...est_backup_restore_backup_temp_partition.groovy | 2 +-
.../test_backup_restore_bloom_filter.groovy | 3 +-
.../test_backup_restore_clean_restore.groovy | 2 +-
.../backup_restore/test_backup_restore_db.groovy | 2 +-
...t_backup_restore_diff_repo_same_snapshot.groovy | 23 +-
..._backup_restore_dup_without_default_keys.groovy | 3 +-
.../test_backup_restore_exclude.groovy | 2 +-
...backup_restore_force_replace_diff_column.groovy | 2 +-
...kup_restore_force_replace_diff_part_type.groovy | 2 +-
...ckup_restore_force_replace_diff_part_val.groovy | 2 +-
.../test_backup_restore_get_snapshot.groovy | 102 +
.../test_backup_restore_inverted_idx.groovy | 2 +-
.../test_backup_restore_inverted_index.groovy | 3 +-
.../backup_restore/test_backup_restore_mtmv.groovy | 2 +-
.../test_backup_restore_multi_tables.groovy | 2 +-
...st_backup_restore_multi_tables_overwrite.groovy | 2 +-
.../backup_restore/test_backup_restore_mv.groovy | 2 +-
.../test_backup_restore_ngram_bloom_filter.groovy | 2 +-
.../test_backup_restore_overwrite_indexes.groovy | 2 +-
.../test_backup_restore_partition.groovy | 2 +-
..._restore_reserve_dynamic_partition_false.groovy | 3 +-
...p_restore_reserve_dynamic_partition_true.groovy | 3 +-
.../test_backup_restore_storage_policy.groovy | 2 +-
.../test_backup_restore_table_auto_bucket.groovy | 3 +-
.../test_backup_restore_version_revert.groovy | 2 +-
.../test_backup_restore_with_hdfs.groovy | 2 +-
..._backup_restore_with_two_phase_fetch_opt.groovy | 2 +-
.../test_backup_restore_with_view.groovy | 2 +-
.../test_backup_store_with_db_properties.groovy | 2 +-
.../test_backup_store_with_db_properties_kv.groovy | 2 +-
.../test_duplicate_backup_restore.groovy | 5 +-
.../test_restore_mix_exists_and_new_table.groovy | 2 +-
.../test_restore_to_new_table.groovy | 3 +-
.../test_unique_backup_restore.groovy | 5 +-
.../test_backup_restore_with_many_tables.groovy | 2 +-
.../bitmap_functions/test_bitmap_intersect.groovy | 2 -
.../check_before_quit/check_before_quit.groovy | 106 +-
.../node_mgr/test_rename_compute_group.groovy | 214 ++
.../tablets/test_clean_stale_rs_file_cache.groovy | 2 +-
...=> test_clean_stale_rs_index_file_cache.groovy} | 14 +-
.../cold_data_compaction_by_hdfs.groovy | 129 ++
.../test_base_compaction_after_sc.groovy | 73 +
...e_compaction_with_variant_inverted_index.groovy | 40 +-
regression-test/suites/compression_p0/load.groovy | 38 +-
.../query.groovy} | 45 +-
.../duplicate/test_duplicate_table.groovy | 1 -
.../test_duplicate_table_without_keys.groovy | 3 -
.../unique/test_sequence_multi_same_key.groovy | 2 -
.../data_model_p0/unique/test_unique_bitmap.groovy | 2 -
.../data_model_p0/unique/test_unique_table.groovy | 2 -
.../date/test_default_current_timestamp.groovy | 1 -
.../suites/datatype_p0/ip/test_ip_crud.groovy | 4 -
.../suites/demo_p0/streamLoad_action.groovy | 5 -
.../suites/empty_relation/eliminate_empty.groovy | 173 ++
.../cloud/test_cloud_full_compaction_mow.groovy | 107 +
.../test_cloud_mow_new_tablet_compaction.groovy | 4 +-
...test_cloud_sc_self_retry_with_stop_token.groovy | 76 +
.../test_first_delete_compaction.groovy | 111 +
.../test_full_compaction_mow.groovy | 98 +
.../test_insert_error_url.groovy | 67 +
.../suites/index_p0/test_bitmap_index.groovy | 1 -
.../suites/insert_p0/test_struct_insert.groovy | 101 +-
.../operate_internal_schema.groovy | 1 -
.../inverted_index_p0/load/test_insert.groovy | 18 +-
.../inverted_index_p0/load/test_stream_load.groovy | 18 +-
.../test_pk_no_need_read_data.groovy | 13 +-
...sted_index_file_http_action_with_variant.groovy | 33 +-
.../test_variant_index_format_v1.groovy | 27 +-
.../test_routin_load_abnormal_job_monitor.groovy | 5 +-
...test_routine_load_job_info_system_table.groovy} | 117 +-
.../load_p0/stream_load/test_csv_split_line.groovy | 3 -
.../load_p0/stream_load/test_stream_load.groovy | 2 +-
.../stream_load/test_stream_load_empty_file.groovy | 64 +-
.../test_stream_load_with_filtered_rows.groovy | 94 +
.../suites/load_p2/test_single_replica_load.groovy | 27 +-
.../suites/mtmv_p0/test_iot_recycle_mtmv.groovy | 68 +
.../test_dup_mv_useless/test_dup_mv_useless.groovy | 11 +-
regression-test/suites/mv_p0/unique/unique.groovy | 5 +
.../mv_p0/unique_rewrite/unique_rewrite.groovy | 12 +-
.../testSelectMVWithTableAlias.groovy | 5 +-
.../nereids_p0/aggregate/aggregate_count1.groovy | 1 -
.../aggregate_group_by_metric_type.groovy | 2 -
.../aggregate/aggregate_grouping_function.groovy | 2 -
.../aggregate/aggregate_having_grouping.groovy | 2 -
.../aggregate/aggregate_output_null.groovy | 3 -
.../suites/nereids_p0/datatype/test_datev1.groovy | 2 -
.../nereids_p0/datatype/test_decimalv2.groovy | 2 -
.../fold_constant/fold_constant_cast.groovy | 49 +
.../fold_constant_date_arithmatic.groovy | 10 +
.../fold_constant_numeric_arithmatic.groovy | 47 +-
.../fold_constant_string_arithmatic.groovy | 990 +++++++-
.../test_conditional_function.groovy | 2 -
...st_date_or_datetime_computation_negative.groovy | 2 -
.../json_function/test_query_json_array.groovy | 1 -
.../json_function/test_query_json_insert.groovy | 1 -
.../json_function/test_query_json_object.groovy | 1 -
.../json_function/test_query_json_replace.groovy | 1 -
.../json_function/test_query_json_set.groovy | 1 -
.../test_string_function_like_pushdown.groovy | 2 -
.../suites/nereids_p0/test_data_type_marks.groovy | 1 -
.../nereids_p0/type_inference/test_largeint.groovy | 1 -
.../mv/union_rewrite/usercase_union_rewrite.groovy | 13 +
.../suites/nereids_syntax_p0/group_bit.groovy | 2 -
.../suites/nereids_syntax_p0/rollup/bitmap.groovy | 2 -
.../suites/nereids_syntax_p0/rollup/date.groovy | 2 -
.../test_auto_range_partition.groovy | 2 +-
.../test_dynamic_partition_with_alter.groovy | 2 -
.../multi_partition/test_multi_partition.groovy | 1 -
.../multi_partition/test_range_partition.groovy | 1 -
.../test_partition_serialized_sp.groovy | 134 ++
regression-test/suites/point_query_p0/load.groovy | 60 +-
.../aggregate/aggregate_output_null.groovy | 3 -
.../suites/query_p0/aggregate/array_agg.groovy | 6 -
.../aggregate/map_agg_nested_insert_doris.groovy | 4 -
.../aggregate/select_random_distributed_tbl.groovy | 2 -
.../suites/query_p0/sort/heap_sort.groovy | 46 +
.../conditional_functions/test_ifnull.groovy | 2 -
.../datetime_functions/test_date_function.groovy | 24 +
.../datetime_functions/test_date_trunc.groovy | 8 +
.../test_from_iso8601_date.groovy | 5 -
.../ip_functions/test_ipv4_to_ipv6_function.groovy | 2 -
.../test_is_ip_string_functions.groovy | 2 -
.../ip_functions/test_to_ip_functions.groovy | 2 -
.../json_function/test_query_json_array.groovy | 1 -
.../json_function/test_query_json_insert.groovy | 1 -
.../json_function/test_query_json_replace.groovy | 2 -
.../json_function/test_query_json_set.groovy | 1 -
.../json_functions/test_json_function.groovy | 2 +
.../query_p0/type_inference/test_largeint.groovy | 1 -
...ptive_pipeline_task_serial_read_on_limit.groovy | 126 ++
.../suites/query_profile/scanner_profile.groovy | 108 +
.../query_profile/test_execute_by_frontend.groovy | 92 +
...e_column_with_delete_drop_column_dup_key.groovy | 2 -
.../test_alter_table_column.groovy | 2 -
.../test_dup_keys_schema_change.groovy | 24 +-
.../test_type_length_change.groovy | 83 +
.../test_uniq_keys_schema_change.groovy | 24 +-
.../test_varchar_sc_in_complex.groovy | 537 +++++
.../test_varchar_schema_change.groovy | 2 +-
.../suites/statistics/analyze_stats.groovy | 2 -
.../suites/statistics/test_basic_statistics.groovy | 5 -
.../statistics/test_drop_stats_and_truncate.groovy | 2 -
.../suites/statistics/test_partition_stats.groovy | 2 -
...lace_table.grovvy => test_replace_table.groovy} | 17 +-
regression-test/suites/variant_p0/rqg/rqg6.sql | 66 +
.../test_array_contains_with_inverted_index.groovy | 172 +-
.../with_index/test_array_index_write.groovy | 133 +-
.../test_array_inverted_index_profile.groovy | 164 +-
.../suites/variant_p0/with_index/var_index.groovy | 90 +-
.../vault_p0/database/test_database_vault.groovy | 246 ++
run-be-ut.sh | 1 +
thirdparty/CHANGELOG.md | 4 +
thirdparty/build-thirdparty.sh | 20 +
thirdparty/download-thirdparty.sh | 17 +
.../thrift-0.16-reset-consumed-message-size.patch | 29 +
thirdparty/vars.sh | 7 +
500 files changed, 17279 insertions(+), 3328 deletions(-)
create mode 100644 be/src/cloud/schema_cloud_dictionary_cache.cpp
create mode 100644 be/src/cloud/schema_cloud_dictionary_cache.h
create mode 100644
be/src/exec/schema_scanner/schema_routine_load_job_scanner.cpp
copy
regression-test/suites/query_p0/sql_functions/conditional_functions/test_ifnull.groovy
=> be/src/exec/schema_scanner/schema_routine_load_job_scanner.h (50%)
create mode 100644 be/src/io/tools/CMakeLists.txt
copy {gensrc => be/src/io/tools}/Makefile (100%)
create mode 100644 be/src/io/tools/file_cache_microbench.cpp
create mode 100644 be/src/io/tools/proto/Makefile
copy
regression-test/suites/query_p0/sql_functions/conditional_functions/test_ifnull.groovy
=> be/src/io/tools/proto/microbench.proto (50%)
create mode 100644 be/src/io/tools/readme.md
create mode 100644 be/test/cloud/cloud_cumulative_compaction_policy_test.cpp
create mode 100644 be/test/cloud/test_schema_cloud_dictionary_cache.cpp
create mode 100644 be/test/olap/compaction_permit_limiter_test.cpp
create mode 100644 be/test/vec/columns/column_object_test.cpp
create mode 100644 be/test/vec/function/function_sub_replace_test.cpp
create mode 100644 be/test/vec/function/simple_function_factory_test.cpp
create mode 100644 dist/licenses/LICENSE-icu.txt
rename fe/fe-core/src/main/java/org/apache/doris/common/{util =>
profile}/AggCounter.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/common/{util =>
profile}/Counter.java (98%)
rename fe/fe-core/src/main/java/org/apache/doris/common/{util =>
profile}/RuntimeProfile.java (95%)
rename
fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/executor/{TableCollector.java
=> TableCollectAndHookInitializer.java} (85%)
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/StrLeft.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/StrRight.java
rename
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{Dlog1.java
=> YearOfWeek.java} (61%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/AlterSystemRenameComputeGroupCommand.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/IndexTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/cloud/cache/CacheHotspotManagerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/profile/AutoProfileTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/profile/ProfileManagerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/profile/ProfilePersistentTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/profile/RuntimeProfileMergeTest.java
rename fe/fe-core/src/test/java/org/apache/doris/common/{util =>
profile}/RuntimeProfileTest.java (91%)
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/util/ProfilePersistentTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/util/UtilTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/EliminateEmptyRelationTest.java
rename regression-test/data/compression_p0/{load.out => query.out} (86%)
copy regression-test/data/{load_p0/stream_load/test_stream_load_empty_file.out
=> fault_injection_p0/cloud/test_cloud_full_compaction_mow.out} (71%)
copy
regression-test/data/fault_injection_p0/cloud/{test_cloud_mow_new_tablet_compaction.out
=> test_cloud_sc_self_retry_with_stop_token.out} (73%)
copy regression-test/data/{load_p0/stream_load/test_stream_load_empty_file.out
=> fault_injection_p0/test_first_delete_compaction.out} (83%)
copy
regression-test/data/fault_injection_p0/{cloud/test_cloud_mow_new_tablet_compaction.out
=> test_full_compaction_mow.out} (68%)
create mode 100644 regression-test/data/query_p0/sort/heap_sort.csv
copy
regression-test/data/{mv_p0/ut/testSelectMVWithTableAlias/testSelectMVWithTableAlias.out
=> query_p0/sort/heap_sort.out} (50%)
rename
regression-test/data/query_p2/string_over_flow/{load_from_big_lateral_view.out
=> string_over_flow.out} (100%)
create mode 100644
regression-test/data/schema_change_p0/test_type_length_change.out
create mode 100644
regression-test/data/schema_change_p0/test_varchar_sc_in_complex.out
create mode 100644 regression-test/data/variant_p0/rqg/rqg6.out
create mode 100644 regression-test/plugins/plugin_multi_cluster.groovy
copy
regression-test/suites/{query_p0/sql_functions/conditional_functions/test_ifnull.groovy
=> account_p0/test_root_user.groovy} (50%)
create mode 100644
regression-test/suites/backup_restore/test_backup_restore_get_snapshot.groovy
create mode 100644
regression-test/suites/cloud_p0/node_mgr/test_rename_compute_group.groovy
copy
regression-test/suites/cloud_p0/tablets/{test_clean_stale_rs_file_cache.groovy
=> test_clean_stale_rs_index_file_cache.groovy} (92%)
create mode 100644
regression-test/suites/cold_heat_separation/cold_data_compaction_by_hdfs.groovy
create mode 100644
regression-test/suites/compaction/test_base_compaction_after_sc.groovy
copy
regression-test/suites/{query_p0/sql_functions/conditional_functions/test_ifnull.groovy
=> compression_p0/query.groovy} (50%)
create mode 100644
regression-test/suites/fault_injection_p0/cloud/test_cloud_full_compaction_mow.groovy
create mode 100644
regression-test/suites/fault_injection_p0/cloud/test_cloud_sc_self_retry_with_stop_token.groovy
create mode 100644
regression-test/suites/fault_injection_p0/test_first_delete_compaction.groovy
create mode 100644
regression-test/suites/fault_injection_p0/test_full_compaction_mow.groovy
create mode 100644
regression-test/suites/fault_injection_p0/test_insert_error_url.groovy
copy
regression-test/suites/load_p0/routine_load/{test_routin_load_abnormal_job_monitor.groovy
=> test_routine_load_job_info_system_table.groovy} (56%)
create mode 100644
regression-test/suites/load_p0/stream_load/test_stream_load_with_filtered_rows.groovy
create mode 100644 regression-test/suites/mtmv_p0/test_iot_recycle_mtmv.groovy
create mode 100644
regression-test/suites/nereids_p0/expression/fold_constant/fold_constant_cast.groovy
create mode 100644
regression-test/suites/partition_p0/test_partition_serialized_sp.groovy
create mode 100644 regression-test/suites/query_p0/sort/heap_sort.groovy
create mode 100644
regression-test/suites/query_profile/adaptive_pipeline_task_serial_read_on_limit.groovy
create mode 100644 regression-test/suites/query_profile/scanner_profile.groovy
create mode 100644
regression-test/suites/query_profile/test_execute_by_frontend.groovy
create mode 100644
regression-test/suites/schema_change_p0/test_type_length_change.groovy
create mode 100644
regression-test/suites/schema_change_p0/test_varchar_sc_in_complex.groovy
rename regression-test/suites/statistics/{test_replace_table.grovvy =>
test_replace_table.groovy} (82%)
create mode 100644 regression-test/suites/variant_p0/rqg/rqg6.sql
create mode 100644
regression-test/suites/vault_p0/database/test_database_vault.groovy
create mode 100644
thirdparty/patches/thrift-0.16-reset-consumed-message-size.patch
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
