This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
omit f0da8c60f6b 4.0.0-rc01
add 06bfd0c3d23 [Bug](runtime-filter) use skip_process to replace
terminate (#55942)
add 427dde0d0b3 [test](paimon) Add more paimon cases (#55893)
add a860f9c1212 [improve](system-table) active_queries add user field
(#55554)
add f30ee9954fb [chore](case) log out msg to find reason of case failure
(#55892)
add b167c503418 [chore](case) make insert_values work with group commit
(#56026)
add a229c38115d [minor](task) Modify task metrics (#56045)
add 041a5a5f6fe [regression](show)fix show load warnings (#56020)
add 37a3d1dd19b [feature](function) Support more types for to_json (#55877)
add 674c348b9cd [fix](cast) Fix the incorrect nullable property setting
for variant cast to JSON. (#55899)
add c3612374bb3 [chore](cloud) Update build and start script (#56031)
add 5d331d892bb [Fix](datetime) Fix scale precision problems of datetime
in fold constant (#55928)
add 7b222ee3a14 [chore](build) Optimize build script (#56027)
add 25db11ce702 [chore](cloud) Add drop_snapshot method (#55958)
add a3fce529360 [fix](decimal256) fix decimal256 multiply overflow (#56025)
add 961182b765d [feature](varbinary) support varbinary type for MYSQL
catalog (#55651)
add 254dfa90529 [fix](filereader) Close LocalFileReader gracefully (#56049)
add 8aef7c1d421 [fix](union) Local shuffle for union operator (#56048)
add e833b970301 [opt](ann index) Support scalar quantization (#55812)
add d8224c4a3d7 [fix](nereids) not use cte split multi distinct when agg
has source repeat (#55907)
add c31b1e9da0c [Fix](cloud-mow) Fix wrong tablet_id in delete bitmap
(#55771)
add cbfafdc81d1 [feat](cloud) Add snapshot manager (#55976)
add b51fa476c94 [Enhancement](nereids) delete translateToLegacyStmt in
CreateMTMVCommand (#54999)
add 612a5cbd396 [Optimize](ShortCircuit) Avoid unnecessary overheap in FE
(#56069)
add a950edff82d [feature](doris-future) Support "map_entries" and
"map_contains_entry" functions (#54036)
add f4b1548a4d6 [test](catalog)add obs and gcs test (#55925)
add 3700d0c0d15 [chore](cloud) Add optional code dir enterprise/ (#56071)
add 06bba3e0c14 [chore](opt) Avoid extra copies of string types in
histogram_to_json. (#55882)
add 5b7825065c2 [chore](test)Icebebrg test uses doris's fileio (#55952)
add 85009ecae53 [fix](mtmv)fix mtmv can not refresh when a partition table
not have partition (#55468)
add 4adb321c9bd [fix](nereids)fix load command failed with bitmap column
expr mapping (#53918)
add 980be15d1ec [chore](auditlog) Enable audit log plugin by default
(#56077)
add 73546b773a6 [Fix](AI) remove thread_pool in AI Functions (#56057)
add 0baff030167 [fix](nereids) agg table does not support
topn-lazy-materialization (#55883)
add ce71c3497f4 [fix](load) Fix src slot mapping issue when file columns
are not explicitly specified (#56041)
add 2f77051817f [bugfix](workloadgroup) add strip quotes for workload
group name in related command (#56084)
add c2534770a20 [fix](exchange) remove const_cast in VDataStreamMgr
(#56088)
add a7ad1ee12b5 [chore](case) move cases who using hdfs to external
(#55987)
add af1ca83d515 [fix](case) fix case bug (#55985)
add 5be8b92c8a0 [case](tvf) add tvf abnormal cases (#56072)
add bef8f369ad5 [fix](compaction) Make creating tablet idempotently to
keep compaction Job idempotent (#56061)
add 5eafeee67d1 [fix](test) Fix mv case wrongly and fix mv rewrite fail
when sync mv used all agg table group by field (#55878)
add b3d33193f89 [regression](filecache): remove unnecessary injection code
(#54268)
add b875bff0db4 [feat](snapshot) support cloud snapshot commands (#55944)
add d18a4878e1e [fix](tde) Correct encryption key version display (#56092)
add 9e6da1ee7cd [opt](ann index) Support cast expression as rhs of
approximate top n (#55458)
add b492ce1d3cb [test](inverted index) fix case for spark load of inverted
index table (#56054)
add 423fffda724 [Chore](nereids) remove CreateTableStmt and CreateMTMVStmt
(#55522)
add cb6a882291a [chore](profile) Minor modification (#55913)
add ddb691987a8 [fix](case) fix global vars used in cases (#55933)
add eba8b7a6507 [opt](coercion) change the coercion behavior (#55672)
add fc1b3ecdac4 [feature](regression) add support to run export cases on
multi bes (#55981)
add 67302d84219 [fix](nereids) fix simplify compare predicate cause by
loss precision or cast null (#55884)
add 54f60de478a [fix](view)Fix show create view not display
column_definition (#55819)
add 3e1e8883911 [enhance](auth)Check basic information when creating a row
policy (#55409)
add 0406ebdbef8 [tool](filecache) add debugging facilities for lru dump
(#54412)
add 10713e9e7f8 [Fix](date) Fix the issue that the ceil func of date
ignores ms (#56070)
add 91ef75352cf [regression-test](functions) Add some date functions cases
of docs (#55839)
add 4b008033ce0 [fix](nereids) Fix profile lock table,translate summary
time err and add ut test (#52601)
add 39d10ad892e [chore](case) add nan/inf case for some math function
(#56099)
add 94677b486d6 [log](info) Print stack trace for assert_cast (#56091)
add e0f115ae038 [chore](cast) Simplify the execution of castexpr. (#56090)
add 1e3f96e127f [fix](group commit) fix content length in stream load
(#56100)
add 489db8125ba [improve](nereids) if a value occurs many times in a
column, take it as hot value (#55827)
add 7672034aef6 [minor](parquet) Refine parquet reader (#56105)
add 483300420c3 [fix](LargeInt)Fix large int max_value + 1 not overflow
bug. (#56083)
add a74d2e04b82 [fix](cloud) set code,msg for snapshot related methods
(#56097)
add 4815ef29e75 [chore](cloud) Add recycle snapshot skeleton (#56098)
add 173e2489fe1 [feat](table) let compress type be configable (#56074)
add 853033615ad [Bug](bits) fix wrong result of count_zero_num with
nullmap (#56113)
add 8ce0d2642f9 [feature](schema)add sql_block_rule_status system table
(#55700)
add 3fbcc530fb7 [fix](test) fix
test_simplify_comparison_predicate_int_vs_double due to merging affected PRs
simultaneously (#56126)
add 5ce957e41b5 [fix](case) improve error logging (#56128)
add 5cef9c7f867 [Chore](nereids) remove SetStmt (#56080)
add 7b9e6a86135 [refactor](variant) use read type to insert default when
compaction (#56066)
add ec98e85d897 [test](iceberg) add iceberg rest obs gcs hdfs test (#56076)
add 02bbc36f939 Revert "[feature](inverted index) introduce config
enable_new_partition_inverted_index_v2_format to set new partiton inverted
index format v2 (#55069) (#56134)
add e66a2d44521 [fix](nereids) fix broker load with negative failed
(#56101)
add 193bccfe7a1 [fix](top rf)fix abs(column) topn rf assert_cast fail.
(#55903)
add 952759219dc [Enhancement](nereids) optimize tableRef in Backup command
(#56095)
add ef93ba07d9f [fix](group commit) fix insert into
insert_max_filter_ratio does not work (#56133)
add 3de3322f277 [fix](function) use need_replace_null_data_to_default for
function round (#56129)
add 37f9b462fe3 [chore](cloud) add DORIS_ADDITIONAL_DEFINITIONS to expose
the underlying definitions (#56147)
add 1af59557495 [Enhancement](txn) Fix get version timstamp func (#56145)
add abaa042cf06 [refactor](thrift) remove useless thrift definition and
remove related code (#56102)
add 76ee8ab8c6f [chore](case) fix some failure cases (#56140)
add f05cf95daa2 [fix](virtual slot) Fix grouping scalar function (#56127)
add 7146661fa62 [fix](union) Terminate union sink if sources finished
(#56153)
add 47d972b3786 [feat](load): directly report the first data quality error
in load response (#55666)
add 0869825f0c3 [Fix](microbench) Fix microbench compile err (#56118)
add f7e591b3507 [Enhancement](nereids) optimize legacy partitions (#56132)
add e7880bba1d9 [refine](datatype) Provide a to_string function for
DataTypeSerDe. (#55919)
add 08ddccc94d8 [fix](nereids) default use sql cache and fix some bugs
(#55513)
add 8572a0a467f [Chore](segment) refactor of
SegmentIterator::_next_batch_internal (#56063)
add ab7a784c2c0 [fix](case) fix ccr_syncer_p0/test_txn_insert (#56155)
add e7dd1136ae9 [chore](case) make test_config_prune_delete_sign happy for
cloud mode (#56160)
add 04cc05c0b81 [fix](local shuffle) add distribute exprs to set operation
node (#56157)
add e0c60f35899 [opt](count) select smallest column for count star (#56093)
add a19572ff391 [test] (ut) add ut for segment::get_data_type_of (#56146)
add 87f8248962f [chore](refactor-params)remove old properties (#56163)
add 852f4d6799e [fix](job) do not expose finished before write editlog
(#56168)
add 7f16e31d874 [fix](load_stream) close brpc stream after load stream is
closed (#56120)
add 89830803887 [opt](case) add debug logs (#56176)
add 62a96bace09 [chore](cloud) Save snapshot resource id and return the
object info in clone response (#56179)
add 5e98aad1f88 [feature](cloud) Support query with freshness tolerance
(#53540)
add 9d0110e715d [enhance](variant) Add some metrics for querying variant
in the profile (#55941)
add 1b890338f88 [fix](cache stat) add builder stat to scanner (#56165)
add bff47ec0759 [fix](test) try to fix two filecache regresion test case
(#56195)
add b0123faa0e6 [fix](storage): Ensure TOO_MANY_VERSION error to be
correctly detected and triggered in RowsetBuilder (#55751)
add 8524079c3d3 [opt](txn) limit publishing txns on a table (#54230)
add ea0e95f4c95 [opt](load) limit concurrency of delete_bitmap computation
(#52962)
add 72e1080eb21 [opt](coercion) String type has the highest precedence in
contexts other than comparison expressions. (#56172)
add ded661503a9 [minor](refactor) Refine orc/parquet readers (#56187)
add 70ad298789b [Opt](cloud-mow) BE can limit the size of
`get_delete_bitmap` response roughly (#55712)
add 4d52e23b4fc [feature](regression test & stream-load) Add the
enableUtf8Encoding field to control the behavior of the HTTP client encoding
header. (#56205)
add 14c7745b962 [Refactor](cast) Remove old cast to datelike type codes
(#55887)
add d5ffa12db4c [Fix](date) Fix the wrong result of str_to_date when input
is Time type (#56192)
add 8dc41eab13d [fix](export) avoid throw npe when export task has illegal
url (#56161)
add eae985648ef [fix](fold constant) abs's return type should be argument
type (#56190)
add 944b4e54121 [fix](sc) Skip empty rowset version hole filling for
versions <= alter_version (#56209)
add 2ce06f04705 [Chore](fragment) some refactor of PipelineFragmentContext
(#56177)
add 29511878a81 [fix](jdbc catalog) Use SQL to get column without using `
enclosed (#55922)
add 1ce7bf0d46f [fix](coordinator) Fix wrong bucket assignments by nereids
coordinator (#56201)
add 84cb785d863 [fix](iceberg) Fix classloader usage in the Iceberg system
table scanner (#56150)
add 7f9b130c1d3 [fix](nereids) runtime filter generation bug for topn lazy
materialization (#56137)
add 3e9b5600c0e [chore](test) improve coverage of function_jsonb.cpp
(#56151)
add d9e5a115acb [chore](task) set tablet id in create finish req and skip
warn for drop (#56178)
add 598073fef26 [Bug](type) add PGenericType for varbinary type (#56188)
add 058e31d3f70 [fix](nereids)useless common sub expression is inferred
for aggregation (#55815)
add a64e6a3fb2b [fix](test) fix test_routine_load_alter case fail (#56206)
add b776be4fbd7 [enhance](metric)add metrics for statistics/mtmv/sql
cache/plan (#55617)
add ac8b1b15020 [test](exchange) set _send_multi_blocks only false (#56211)
add 56d6863f31a [enhance](mtmv)log snapshot after task finish (#56198)
add 1edd28f2a68 [fix](nereids) fix bugs about convert hot value from
string type to date type (#56185)
add e602e48e30b [Fix](Catalog)S3A: Support assuming IAM role via
ProfileCredentialsProvider (#56213)
add f0f26d7c7da [fix](script) Fix recycler cannot find `core-site.xml` and
`hdfs-site.xml` (#56248)
add 972941b0c15 [fix](prepare statement)Prepare stage only explain sql to
get output slots. (#56224)
add 643caa7f5c9 [fix](count) fix wrong count push down logic (#56182)
add f8fac2d2a15 [fix](multi-catalog) should set initedScanRangeLocations
after getScanRangeLocations (#56245)
add 03c3afd3c1a [improvement](load) improve load strict mode (#55902)
add 99d000bbdd5 [fix](cloud) make recycle_snapshot_meta_and_data public
(#56240)
add 1364d3670e3 [Feat](Snapshot) Support Snapshot MS Http Interface
(#56202)
add 23acc85a58a [fix](cases) add load ddl test cases (#56263)
add 242444b2ecc [Refactor](function) Throw exception rather than return
null for datetime function error handling (#56079)
add 6131f4633a2 [fix](function) incorrect result of json_extract with path
'**' (#56226)
add d7c9e5ec3a0 [fix](file writer) fix value of s3 bytes written bvar
incorrect (#56262)
add 4717a022fe4 [fix](test) Reduce cache cleanup interval to fix flaky
test (#56253)
add 79ddf566cc9 [Chore](auto-pick)4.0.x autopick (#56282)
add 9076cc3a96e [opt](exec) opt the row id fetcher performance (#56222)
add d46a04ea0c2 [feature](function) add is_ipv4/is_ipv6 (#56255)
add 41aeb12ffcc [fix](nereids)fix tableNameInfo is null in tableRefInfo
(#56219)
add 317d5601acb [opt](ai) detail optimization for AI Funcion (#55762)
add d61d2cbfa57 [fix](nereids) fix unstable test of sql cache (#56264)
add dd4c598e769 [Fix](datetime) fix wrong implicit microsecond digits
after reducing precision of datetime (#53659)
add 8d9c5d65176 [enhance](mtmv)Base table changes should not cause nested
MTMV to schema change status (#56244)
add 9b39be28eeb [fix](docker case) Fix warm up case failed due to schema
change (#56252)
add cf536ab068d [fix](regression) fix unstable case cse.groovy (#56227)
add cf84078447e [fix](case) test_csv_with_header (#56107)
new e031d4e6ae5 4.0.0-rc02
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (f0da8c60f6b)
\
N -- N -- N refs/heads/branch-4.0 (e031d4e6ae5)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/auto-cherry-pick.yml | 10 +-
.licenserc.yaml | 2 +
be/CMakeLists.txt | 3 +
be/src/agent/task_worker_pool.cpp | 16 +-
be/src/cloud/cloud_delta_writer.cpp | 5 +
be/src/cloud/cloud_internal_service.cpp | 92 +-
be/src/cloud/cloud_meta_mgr.cpp | 185 +-
be/src/cloud/cloud_meta_mgr.h | 5 +
be/src/cloud/cloud_schema_change_job.cpp | 18 +-
be/src/cloud/cloud_storage_engine.cpp | 9 +-
be/src/cloud/cloud_storage_engine.h | 13 +
be/src/cloud/cloud_tablet.cpp | 270 +-
be/src/cloud/cloud_tablet.h | 92 +-
be/src/cloud/cloud_warm_up_manager.cpp | 44 +-
be/src/cloud/config.cpp | 7 +
be/src/cloud/config.h | 3 +
be/src/cloud/injection_point_action.cpp | 9 -
be/src/cloud/pb_convert.cpp | 12 +
be/src/common/config.cpp | 9 +-
be/src/common/config.h | 9 +-
be/src/common/status.h | 2 +-
be/src/exec/rowid_fetcher.cpp | 210 +-
be/src/exec/rowid_fetcher.h | 7 +-
be/src/exec/schema_scanner.cpp | 3 +
.../schema_active_queries_scanner.cpp | 1 +
.../schema_encryption_keys_scanner.cpp | 3 +-
.../schema_sql_block_rule_status_scanner.cpp | 164 +
.../schema_sql_block_rule_status_scanner.h | 56 +
be/src/exec/table_connector.h | 3 -
be/src/http/action/delete_bitmap_action.cpp | 8 +
be/src/http/action/file_cache_action.cpp | 3 +
be/src/http/action/http_stream.cpp | 1 +
be/src/http/action/stream_load.cpp | 14 +-
be/src/io/CMakeLists.txt | 25 +
be/src/io/cache/block_file_cache.cpp | 68 +-
be/src/io/cache/block_file_cache.h | 15 +-
be/src/io/cache/block_file_cache_factory.cpp | 6 +
be/src/io/cache/block_file_cache_factory.h | 5 +
be/src/io/cache/block_file_cache_profile.cpp | 2 +-
be/src/io/cache/cache_lru_dumper.cpp | 53 +-
be/src/io/cache/cache_lru_dumper.h | 17 +-
be/src/io/cache/cached_remote_file_reader.cpp | 21 +
be/src/io/cache/file_cache_common.h | 2 +
be/src/io/cache/file_cache_lru_tool.cpp | 233 ++
be/src/io/fs/local_file_reader.cpp | 10 +-
be/src/io/fs/multi_table_pipe.cpp | 9 +-
be/src/io/fs/s3_file_writer.cpp | 1 +
be/src/io/io_common.h | 2 +
be/src/io/tools/file_cache_microbench.cpp | 15 +-
be/src/olap/base_tablet.h | 29 +-
be/src/olap/calc_delete_bitmap_executor.cpp | 5 +-
be/src/olap/calc_delete_bitmap_executor.h | 2 +-
be/src/olap/iterators.h | 5 +-
be/src/olap/olap_common.h | 8 +
be/src/olap/parallel_scanner_builder.cpp | 2 +-
be/src/olap/parallel_scanner_builder.h | 3 +
be/src/olap/partial_update_info.cpp | 6 +-
be/src/olap/push_handler.cpp | 3 -
be/src/olap/rowset/beta_rowset.cpp | 7 +-
be/src/olap/rowset/beta_rowset.h | 3 +-
be/src/olap/rowset/beta_rowset_reader.cpp | 2 +-
be/src/olap/rowset/beta_rowset_writer.cpp | 2 +-
be/src/olap/rowset/rowset.cpp | 4 +
be/src/olap/rowset/rowset.h | 2 +
be/src/olap/rowset/rowset_meta.h | 17 +
.../olap/rowset/segment_v2/ann_index/ann_index.h | 5 +-
.../segment_v2/ann_index/ann_index_reader.cpp | 8 +
.../rowset/segment_v2/ann_index/ann_index_reader.h | 4 +-
.../segment_v2/ann_index/ann_index_writer.cpp | 12 +-
.../rowset/segment_v2/ann_index/ann_index_writer.h | 1 +
.../ann_index/ann_range_search_runtime.cpp | 6 +-
.../ann_index/ann_range_search_runtime.h | 29 +-
.../segment_v2/ann_index/ann_search_params.h | 2 +-
.../segment_v2/ann_index/ann_topn_runtime.cpp | 149 +-
.../rowset/segment_v2/ann_index/ann_topn_runtime.h | 5 +-
.../segment_v2/ann_index/faiss_ann_index.cpp | 52 +-
.../rowset/segment_v2/ann_index/faiss_ann_index.h | 24 +-
be/src/olap/rowset/segment_v2/segment.cpp | 48 +-
be/src/olap/rowset/segment_v2/segment.h | 3 +-
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 482 ++-
be/src/olap/rowset/segment_v2/segment_iterator.h | 27 +-
.../variant/hierarchical_data_iterator.cpp | 8 +-
.../variant/hierarchical_data_iterator.h | 9 +-
.../variant/sparse_column_extract_iterator.h | 23 +-
.../segment_v2/variant/variant_column_reader.cpp | 7 +-
be/src/olap/rowset_builder.cpp | 38 +-
be/src/olap/storage_engine.cpp | 9 +-
be/src/olap/storage_engine.h | 5 +
be/src/olap/tablet.cpp | 4 +-
be/src/olap/tablet.h | 4 +-
be/src/olap/tablet_meta.cpp | 5 +
be/src/olap/tablet_meta.h | 8 +-
be/src/olap/types.h | 36 +-
be/src/olap/uint24.h | 17 +-
be/src/olap/version_graph.cpp | 208 ++
be/src/olap/version_graph.h | 63 +
be/src/pipeline/exec/cache_sink_operator.cpp | 4 +-
be/src/pipeline/exec/data_queue.cpp | 22 +-
be/src/pipeline/exec/data_queue.h | 4 +-
be/src/pipeline/exec/exchange_sink_buffer.cpp | 3 +-
.../exec/group_commit_block_sink_operator.cpp | 3 +-
be/src/pipeline/exec/hashjoin_build_sink.cpp | 2 +-
be/src/pipeline/exec/olap_scan_operator.cpp | 39 +-
be/src/pipeline/exec/olap_scan_operator.h | 16 +
.../exec/partitioned_hash_join_sink_operator.cpp | 2 +-
be/src/pipeline/exec/set_sink_operator.cpp | 2 +-
be/src/pipeline/exec/union_sink_operator.cpp | 16 +-
be/src/pipeline/exec/union_sink_operator.h | 11 +
be/src/pipeline/exec/union_source_operator.cpp | 12 +
be/src/pipeline/exec/union_source_operator.h | 1 +
be/src/pipeline/pipeline_fragment_context.cpp | 543 +--
be/src/pipeline/pipeline_fragment_context.h | 34 +-
be/src/pipeline/pipeline_task.h | 4 +-
be/src/runtime/define_primitive_type.h | 39 +-
be/src/runtime/exec_env.h | 7 +
be/src/runtime/fold_constant_executor.cpp | 8 +-
be/src/runtime/fragment_mgr.cpp | 26 +-
be/src/runtime/fragment_mgr.h | 6 -
be/src/runtime/group_commit_mgr.cpp | 3 +
be/src/runtime/load_stream.cpp | 25 +-
be/src/runtime/load_stream.h | 4 +-
be/src/runtime/primitive_type.cpp | 8 +-
be/src/runtime/primitive_type.h | 23 +
be/src/runtime/query_context.cpp | 10 +
be/src/runtime/query_context.h | 4 +
.../routine_load/routine_load_task_executor.cpp | 12 +-
be/src/runtime/runtime_state.cpp | 34 +-
be/src/runtime/runtime_state.h | 25 +-
be/src/runtime/stream_load/stream_load_context.cpp | 19 +-
be/src/runtime/stream_load/stream_load_context.h | 1 +
.../runtime/stream_load/stream_load_executor.cpp | 14 +-
be/src/runtime_filter/runtime_filter_producer.cpp | 2 -
.../runtime_filter_producer_helper.cpp | 13 -
.../runtime_filter_producer_helper.h | 3 +-
be/src/service/backend_service.cpp | 63 -
be/src/service/backend_service.h | 23 -
be/src/service/internal_service.cpp | 52 +-
be/src/service/point_query_executor.cpp | 6 +-
be/src/util/asan_util.h | 15 +-
be/src/util/jsonb_document.cpp | 16 +
be/src/util/simd/bits.h | 2 +-
.../vec/aggregate_functions/aggregate_function.h | 3 +
.../aggregate_function_ai_agg.h | 17 +
be/src/vec/columns/column_varbinary.cpp | 181 +
be/src/vec/columns/column_varbinary.h | 171 +
be/src/vec/columns/column_vector.h | 6 +-
be/src/vec/common/arithmetic_overflow.h | 45 +-
be/src/vec/common/string_view.cpp | 56 +
be/src/vec/common/string_view.h | 157 +
be/src/vec/core/column_with_type_and_name.cpp | 13 +-
be/src/vec/core/column_with_type_and_name.h | 2 +-
be/src/vec/core/field.cpp | 24 +-
be/src/vec/core/field.h | 16 +-
be/src/vec/data_types/data_type.cpp | 3 +
be/src/vec/data_types/data_type.h | 2 +
.../data_types/data_type_date_or_datetime_v2.cpp | 3 +-
.../vec/data_types/data_type_date_or_datetime_v2.h | 7 +-
be/src/vec/data_types/data_type_decimal.h | 6 +-
be/src/vec/data_types/data_type_factory.cpp | 4 +
be/src/vec/data_types/data_type_nullable.cpp | 3 +-
be/src/vec/data_types/data_type_time.cpp | 2 +-
be/src/vec/data_types/data_type_time.h | 6 +-
be/src/vec/data_types/data_type_varbinary.cpp | 157 +
be/src/vec/data_types/data_type_varbinary.h | 106 +
.../vec/data_types/serde/data_type_array_serde.cpp | 19 +
.../vec/data_types/serde/data_type_array_serde.h | 2 +
.../data_types/serde/data_type_datetimev2_serde.h | 1 +
.../data_types/serde/data_type_decimal_serde.cpp | 24 +
.../vec/data_types/serde/data_type_decimal_serde.h | 4 +
.../vec/data_types/serde/data_type_jsonb_serde.cpp | 12 +
.../vec/data_types/serde/data_type_jsonb_serde.h | 2 +
.../vec/data_types/serde/data_type_map_serde.cpp | 64 +
be/src/vec/data_types/serde/data_type_map_serde.h | 5 +
.../data_types/serde/data_type_nullable_serde.cpp | 10 +
.../data_types/serde/data_type_nullable_serde.h | 2 +
.../data_types/serde/data_type_number_serde.cpp | 87 +-
.../vec/data_types/serde/data_type_number_serde.h | 5 +
be/src/vec/data_types/serde/data_type_serde.cpp | 15 +
be/src/vec/data_types/serde/data_type_serde.h | 4 +
.../data_types/serde/data_type_string_serde.cpp | 15 +
.../vec/data_types/serde/data_type_string_serde.h | 2 +
.../data_types/serde/data_type_struct_serde.cpp | 13 +
.../vec/data_types/serde/data_type_struct_serde.h | 2 +
be/src/vec/data_types/serde/data_type_time_serde.h | 1 +
.../data_types/serde/data_type_varbinary_serde.cpp | 68 +
...variant_serde.h => data_type_varbinary_serde.h} | 53 +-
.../data_types/serde/data_type_variant_serde.cpp | 6 +
.../vec/data_types/serde/data_type_variant_serde.h | 1 +
be/src/vec/exec/format/generic_reader.h | 13 +-
be/src/vec/exec/format/orc/vorc_reader.cpp | 13 +-
be/src/vec/exec/format/orc/vorc_reader.h | 40 +-
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 23 +-
be/src/vec/exec/format/parquet/vparquet_reader.h | 8 +-
be/src/vec/exec/format/table/iceberg_reader.h | 7 +-
.../vec/exec/format/table/table_format_reader.cpp | 11 +-
be/src/vec/exec/format/table/table_format_reader.h | 21 +-
be/src/vec/exec/jni_connector.cpp | 46 +-
be/src/vec/exec/jni_connector.h | 3 +
be/src/vec/exec/scan/file_scanner.cpp | 18 +-
be/src/vec/exec/scan/olap_scanner.cpp | 25 +-
be/src/vec/exec/vjdbc_connector.h | 5 -
be/src/vec/exprs/vcast_expr.cpp | 29 +-
be/src/vec/exprs/vectorized_fn_call.cpp | 61 +-
be/src/vec/exprs/vexpr.cpp | 3 +-
be/src/vec/exprs/vtopn_pred.h | 21 +-
be/src/vec/functions/ai/ai_adapter.h | 188 +-
be/src/vec/functions/ai/ai_functions.h | 155 +-
.../vec/functions/array/function_array_range.cpp | 2 +-
be/src/vec/functions/cast/cast_to_date.h | 55 +-
be/src/vec/functions/cast/cast_to_string.h | 190 +-
be/src/vec/functions/cast/cast_to_time_impl.hpp | 5 +-
be/src/vec/functions/cast/function_cast.cpp | 6 +-
be/src/vec/functions/date_time_transforms.h | 192 +-
be/src/vec/functions/datetime_errors.h | 130 +
be/src/vec/functions/function.cpp | 10 +-
be/src/vec/functions/function_convert_tz.cpp | 357 +-
be/src/vec/functions/function_convert_tz.h | 358 --
.../function_date_or_datetime_computation.h | 203 +-
.../function_date_or_datetime_to_something.h | 73 +-
.../function_date_or_datetime_to_string.cpp | 90 +-
.../function_date_or_datetime_to_string.h | 112 -
.../vec/functions/function_datetime_floor_ceil.cpp | 398 ++-
.../functions/function_datetime_string_to_string.h | 85 +-
be/src/vec/functions/function_jsonb.cpp | 291 +-
be/src/vec/functions/function_map.cpp | 437 ++-
...estamp.cpp => function_other_types_to_date.cpp} | 536 ++-
be/src/vec/functions/function_string.h | 14 +-
be/src/vec/functions/functions_comparison.h | 4 +-
be/src/vec/functions/functions_geo.cpp | 2 +-
be/src/vec/functions/round.h | 2 +
be/src/vec/functions/time_of_function.cpp | 4 -
be/src/vec/olap/vcollect_iterator.cpp | 4 +
be/src/vec/runtime/time_value.h | 17 +-
be/src/vec/runtime/vdata_stream_mgr.cpp | 11 +-
be/src/vec/runtime/vdatetime_value.cpp | 445 +--
be/src/vec/runtime/vdatetime_value.h | 21 +-
be/src/vec/sink/load_stream_map_pool.cpp | 6 +-
be/src/vec/sink/load_stream_map_pool.h | 1 +
be/src/vec/sink/load_stream_stub.cpp | 11 +-
be/src/vec/sink/load_stream_stub.h | 4 +-
be/src/vec/sink/tablet_sink_hash_partitioner.cpp | 4 +-
be/src/vec/sink/vrow_distribution.cpp | 5 +-
be/src/vec/sink/vrow_distribution.h | 2 +-
be/src/vec/sink/vtablet_block_convertor.cpp | 104 +-
be/src/vec/sink/vtablet_block_convertor.h | 11 +-
be/src/vec/sink/writer/vtablet_writer.cpp | 4 +-
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 4 +-
be/src/vec/utils/histogram_helpers.hpp | 28 +-
be/src/vec/utils/util.hpp | 14 +
...test.cpp => aggregate_function_ai_agg_test.cpp} | 83 +-
be/test/ai/ai_adapter_test.cpp | 99 +-
...{build_prompt_test.cpp => ai_function_test.cpp} | 27 +
be/test/ai/embed_test.cpp | 6 +-
be/test/cloud/cloud_meta_mgr_test.cpp | 448 +++
.../cloud/cloud_tablet_query_prefer_cache_test.cpp | 804 +++++
.../cloud_tablet_query_with_tolerance_test.cpp | 1074 ++++++
be/test/cloud/cloud_tablet_test.cpp | 84 +-
be/test/common/check_overflow.cpp | 148 +
.../test_data/parquet_scanner/dict-decoder.txt | 32 +-
.../test_data/parquet_scanner/type-decoder.txt | 28 +-
...mev2_0_to_string.out => TimeV2_0_to_string.out} | Bin
..._0_to_string_2.out => TimeV2_0_to_string_2.out} | Bin
..._0_to_string_3.out => TimeV2_0_to_string_3.out} | Bin
...ring_batch.out => TimeV2_0_to_string_batch.out} | Bin
...mev2_5_to_string.out => TimeV2_5_to_string.out} | Bin
..._5_to_string_2.out => TimeV2_5_to_string_2.out} | Bin
..._5_to_string_3.out => TimeV2_5_to_string_3.out} | Bin
...ring_batch.out => TimeV2_5_to_string_batch.out} | Bin
...mev2_6_to_string.out => TimeV2_6_to_string.out} | Bin
..._6_to_string_2.out => TimeV2_6_to_string_2.out} | Bin
..._6_to_string_3.out => TimeV2_6_to_string_3.out} | Bin
...ring_batch.out => TimeV2_6_to_string_batch.out} | Bin
.../vec/data_types/timev2_to_string.out | Bin 468 -> 0 bytes
.../vec/data_types/timev2_to_string_2.out | Bin 468 -> 0 bytes
.../vec/data_types/timev2_to_string_3.out | Bin 468 -> 0 bytes
.../vec/data_types/timev2_to_string_batch.out | Bin 468 -> 0 bytes
be/test/olap/rowid_conversion_test.cpp | 3 +-
.../variant_column_writer_reader_test.cpp | 23 +-
be/test/olap/segcompaction_mow_test.cpp | 3 +-
be/test/olap/segcompaction_test.cpp | 9 +-
be/test/olap/tablet_test.cpp | 4 +-
.../olap/vector_search/ann_index_reader_test.cpp | 4 +-
.../olap/vector_search/ann_range_search_test.cpp | 63 +-
.../vector_search/ann_topn_descriptor_test.cpp | 26 +-
.../ann_topn_runtime_negative_test.cpp | 148 +
be/test/olap/vector_search/vector_search_utils.cpp | 10 +
be/test/pipeline/exec/data_queue_test.cpp | 2 +-
be/test/pipeline/pipeline_task_test.cpp | 3 +-
be/test/pipeline/pipeline_test.cpp | 3 +-
.../runtime_filter_producer_helper_test.cpp | 2 +-
be/test/util/bit_util_test.cpp | 93 +
.../vec/aggregate_functions/agg_function_test.h | 2 +-
be/test/vec/columns/column_varbinary_test.cpp | 477 +++
be/test/vec/columns/common_column_test.h | 101 +-
be/test/vec/common/schema_util_rowset_test.cpp | 60 +-
be/test/vec/common/string_view_test.cpp | 249 ++
.../vec/core/column_with_type_and_name_test.cpp | 6 +-
..._v2_test.cpp => data_type_datetime_v2_test.cpp} | 53 +-
.../vec/data_types/data_type_varbinary_test.cpp | 205 ++
be/test/vec/data_types/from_string_test.cpp | 9 +-
.../data_types/serde/data_type_serde_text_test.cpp | 474 +--
.../serde/data_type_serde_varbinary_test.cpp | 208 ++
.../vec/exec/format/parquet/parquet_read_lines.cpp | 2 +-
.../exec/format/parquet/parquet_thrift_test.cpp | 2 +
be/test/vec/exec/orc/orc_read_lines.cpp | 2 +-
be/test/vec/exprs/vexpr_test.cpp | 15 +-
be/test/vec/function/cast/cast_to_string.cpp | 23 +
be/test/vec/function/function_convert_tz_test.cpp | 59 -
be/test/vec/function/function_jsonb_test.cpp | 85 +-
be/test/vec/function/function_test_util.h | 4 +-
be/test/vec/function/function_time_test.cpp | 618 ++--
.../utils/arrow_column_to_doris_column_test.cpp | 7 +-
bin/start_fe.sh | 12 +-
build.sh | 7 +
cloud/CMakeLists.txt | 93 +-
cloud/script/start.sh | 91 +-
cloud/src/common/bvars.cpp | 48 +
cloud/src/common/bvars.h | 37 +
cloud/src/common/config.h | 4 +
cloud/src/meta-service/meta_server.cpp | 4 +-
cloud/src/meta-service/meta_service.cpp | 57 +-
cloud/src/meta-service/meta_service.h | 30 +-
cloud/src/meta-service/meta_service_http.cpp | 130 +
cloud/src/meta-service/meta_service_job.cpp | 40 +-
cloud/src/meta-service/meta_service_resource.cpp | 11 +
cloud/src/meta-service/meta_service_snapshot.cpp | 219 +-
cloud/src/meta-service/meta_service_txn.cpp | 9 +
cloud/src/meta-service/txn_lazy_committer.cpp | 4 +
cloud/src/meta-store/keys.cpp | 10 +
cloud/src/meta-store/keys.h | 1 +
cloud/src/meta-store/mem_txn_kv.cpp | 11 +-
cloud/src/meta-store/mem_txn_kv.h | 4 +-
cloud/src/meta-store/meta_reader.cpp | 29 +
cloud/src/meta-store/meta_reader.h | 7 +
cloud/src/meta-store/txn_kv.cpp | 10 +-
cloud/src/meta-store/txn_kv.h | 7 +-
cloud/src/recycler/CMakeLists.txt | 4 +
cloud/src/recycler/checker.cpp | 7 +
cloud/src/recycler/recycler.cpp | 44 +-
cloud/src/recycler/recycler.h | 15 +
cloud/src/recycler/recycler_snapshot.cpp | 85 +
cloud/src/snapshot/CMakeLists.txt | 4 +
cloud/src/snapshot/snapshot_manager.cpp | 83 +
cloud/src/snapshot/snapshot_manager.h | 70 +
cloud/test/CMakeLists.txt | 15 +-
cloud/test/fdb_injection_test.cpp | 4 +-
cloud/test/keys_test.cpp | 26 +-
cloud/test/mem_txn_kv_test.cpp | 15 +-
cloud/test/meta_reader_test.cpp | 133 +
cloud/test/meta_server_test.cpp | 9 +-
cloud/test/meta_service_http_test.cpp | 43 +-
cloud/test/meta_service_job_test.cpp | 258 +-
cloud/test/meta_service_snapshot_test.cpp | 2 +-
cloud/test/meta_service_test.cpp | 123 +-
cloud/test/rate_limiter_test.cpp | 3 +-
cloud/test/recycle_versioned_keys_test.cpp | 3 +-
cloud/test/recycler_operation_log_test.cpp | 3 +-
cloud/test/recycler_test.cpp | 12 +-
cloud/test/resource_test.cpp | 3 +-
cloud/test/rpc_kv_bvar_test.cpp | 6 +-
cloud/test/txn_kv_test.cpp | 15 +-
cloud/test/txn_lazy_commit_test.cpp | 3 +-
.../iceberg-rest/docker-compose.yaml.tpl | 130 +-
.../iceberg-rest/iceberg-rest_settings.env | 40 +-
.../kerberos/entrypoint-hive-master.sh | 7 +
.../docker-compose/kerberos/hadoop-hive.env.tpl | 7 +
.../docker-compose/kerberos/kerberos.yaml.tpl | 2 +
.../docker-compose/kerberos/kerberos1_settings.env | 7 +-
.../docker-compose/kerberos/kerberos2_settings.env | 7 +-
...-5414d3da-b984-4a28-a501-e7dc42a1760f-0.parquet | Bin 0 -> 563 bytes
...manifest-3224f4a3-e7f2-402a-b1b1-bd1fe57d57ad-0 | Bin 0 -> 2016 bytes
...est-list-7dbac4ab-1226-4c1f-8346-3b388de65ea3-0 | Bin 0 -> 884 bytes
...est-list-7dbac4ab-1226-4c1f-8346-3b388de65ea3-1 | Bin 0 -> 986 bytes
.../hdfs_db.db/external_test_table/schema/schema-0 | 29 +
.../external_test_table}/snapshot/EARLIEST | 0
.../external_test_table}/snapshot/LATEST | 0
.../external_test_table/snapshot/snapshot-1 | 19 +
.../kerberos/sql/create_paimon_hive_table.hql | 7 +
.../docker-compose/mysql/init/01-drop-db.sql | 1 +
.../docker-compose/mysql/init/02-create-db.sql | 1 +
.../docker-compose/mysql/init/03-create-table.sql | 5 +
.../docker-compose/mysql/init/04-insert.sql | 2 +
.../doris/iceberg/IcebergSysTableJniScanner.java | 60 +-
.../apache/doris/common/jni/vec/ColumnType.java | 14 +-
.../apache/doris/common/jni/vec/VectorColumn.java | 50 +-
.../org/apache/doris/jdbc/BaseJdbcExecutor.java | 6 +
.../org/apache/doris/jdbc/MySQLJdbcExecutor.java | 7 +
.../org/apache/doris/catalog/PrimitiveType.java | 12 +
.../java/org/apache/doris/catalog/ScalarType.java | 24 +
.../main/java/org/apache/doris/catalog/Type.java | 71 +-
.../main/java/org/apache/doris/common/Config.java | 39 +-
.../antlr4/org/apache/doris/nereids/DorisLexer.g4 | 10 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 10 +
.../src/main/java/org/apache/doris/DorisFE.java | 13 +
.../main/java/org/apache/doris/alter/Alter.java | 9 +
.../java/org/apache/doris/alter/AlterJobV2.java | 7 +
.../java/org/apache/doris/alter/RollupJobV2.java | 23 +-
.../apache/doris/alter/SchemaChangeHandler.java | 14 +-
.../org/apache/doris/alter/SchemaChangeJobV2.java | 24 +-
.../doris/analysis/AnnIndexPropertiesChecker.java | 7 +
.../apache/doris/analysis/BuildIndexClause.java | 7 +-
.../java/org/apache/doris/analysis/IndexDef.java | 16 +-
.../org/apache/doris/analysis/LargeIntLiteral.java | 6 +-
.../org/apache/doris/analysis/PartitionDesc.java | 70 +
.../doris/analysis/ReplacePartitionClause.java | 13 +-
.../org/apache/doris/analysis/SchemaTableType.java | 2 +
.../org/apache/doris/analysis/SetLdapPassVar.java | 62 -
.../org/apache/doris/analysis/SetNamesVar.java | 73 -
.../java/org/apache/doris/analysis/SetPassVar.java | 100 -
.../java/org/apache/doris/analysis/SetStmt.java | 108 -
.../org/apache/doris/analysis/SetTransaction.java | 28 -
.../apache/doris/analysis/SetUserPropertyVar.java | 130 -
.../apache/doris/analysis/SinglePartitionDesc.java | 99 +
.../apache/doris/analysis/VarBinaryLiteral.java | 142 +
.../org/apache/doris/backup/BackupHandler.java | 92 +-
.../java/org/apache/doris/backup/BackupJob.java | 38 +-
.../org/apache/doris/backup/BackupJobInfo.java | 70 -
.../java/org/apache/doris/backup/Repository.java | 35 -
.../java/org/apache/doris/backup/RestoreJob.java | 65 +-
.../org/apache/doris/blockrule/SqlBlockRule.java | 22 +
.../apache/doris/blockrule/SqlBlockRuleMgr.java | 25 +-
.../org/apache/doris/catalog/AzureResource.java | 2 +-
.../java/org/apache/doris/catalog/BrokerMgr.java | 5 +-
.../doris/catalog/BuiltinScalarFunctions.java | 8 +-
.../apache/doris/catalog/CatalogRecycleBin.java | 11 +
.../java/org/apache/doris/catalog/Database.java | 29 +
.../main/java/org/apache/doris/catalog/Env.java | 92 +-
.../org/apache/doris/catalog/HdfsStorageVault.java | 9 +-
.../java/org/apache/doris/catalog/HiveTable.java | 6 +-
.../org/apache/doris/catalog/OlapTableFactory.java | 37 +-
.../java/org/apache/doris/catalog/S3Resource.java | 2 +-
.../org/apache/doris/catalog/S3StorageVault.java | 9 +-
.../java/org/apache/doris/catalog/SchemaTable.java | 93 +-
.../org/apache/doris/catalog/StorageVaultMgr.java | 5 +-
.../org/apache/doris/catalog/TableProperty.java | 8 +-
.../org/apache/doris/cloud/catalog/CloudEnv.java | 34 +-
.../apache/doris/cloud/catalog/CloudReplica.java | 23 +-
.../doris/cloud/catalog/CloudTabletRebalancer.java | 6 +-
.../cloud/datasource/CloudInternalCatalog.java | 8 +-
.../apache/doris/cloud/rpc/MetaServiceClient.java | 35 +
.../apache/doris/cloud/rpc/MetaServiceProxy.java | 28 +
.../doris/cloud/snapshot/CloudSnapshotHandler.java | 90 +
.../apache/doris/cloud/snapshot/SnapshotState.java | 52 +
.../apache/doris/cloud/storage/AzureRemote.java | 27 +-
.../apache/doris/cloud/storage/DefaultRemote.java | 33 +
.../org/apache/doris/cloud/storage/MockRemote.java | 11 +
.../org/apache/doris/cloud/storage/RemoteBase.java | 5 +
.../apache/doris/common/CommandLineOptions.java | 12 +
.../cache/NereidsSortedPartitionsCacheManager.java | 4 +
.../doris/common/cache/NereidsSqlCacheManager.java | 265 +-
.../org/apache/doris/common/profile/Profile.java | 2 -
.../doris/common/profile/RuntimeProfile.java | 9 -
.../doris/common/profile/SummaryProfile.java | 90 +-
.../org/apache/doris/common/util/DebugUtil.java | 61 +-
.../apache/doris/common/util/IdGeneratorUtil.java | 20 -
.../org/apache/doris/common/util/PrintableMap.java | 7 +-
.../apache/doris/common/util/PropertyAnalyzer.java | 34 +-
.../org/apache/doris/datasource/CatalogIf.java | 17 +-
.../apache/doris/datasource/ExternalCatalog.java | 45 +-
.../apache/doris/datasource/InternalCatalog.java | 1283 +-------
.../apache/doris/datasource/hive/HiveDlaTable.java | 2 +-
.../doris/datasource/hive/HiveMetadataOps.java | 117 -
.../doris/datasource/hive/source/HiveScanNode.java | 3 +
.../iceberg/IcebergDLFExternalCatalog.java | 16 +-
.../datasource/iceberg/IcebergMetadataOps.java | 58 -
.../datasource/iceberg/source/IcebergScanNode.java | 4 +
.../datasource/jdbc/client/JdbcMySQLClient.java | 9 +-
.../lakesoul/source/LakeSoulScanNode.java | 17 +-
.../datasource/operations/ExternalMetadataOps.java | 17 -
.../datasource/paimon/source/PaimonScanNode.java | 4 +
.../property/constants/AzureProperties.java | 70 -
.../property/constants/S3Properties.java | 336 --
.../metastore/AWSGlueMetaStoreBaseProperties.java | 6 +-
.../metastore/AWSGlueMetaStoreProperties.java | 76 -
.../property/metastore/DataProcProperties.java | 37 -
.../IcebergFileSystemMetaStoreProperties.java | 7 +-
.../metastore/IcebergGlueMetaStoreProperties.java | 5 -
.../metastore/IcebergHMSMetaStoreProperties.java | 25 +-
.../property/metastore/IcebergRestProperties.java | 2 +-
.../IcebergS3TablesMetaStoreProperties.java | 4 +-
.../metastore/PaimonHMSMetaStoreProperties.java | 6 +-
.../property/storage/AzureProperties.java | 5 +-
.../datasource/property/storage/COSProperties.java | 2 -
.../datasource/property/storage/GCSProperties.java | 2 -
.../datasource/property/storage/S3Properties.java | 278 ++
.../datasource/tvf/source/MetadataScanNode.java | 1 +
.../doris/insertoverwrite/InsertOverwriteUtil.java | 6 +-
.../doris/job/extensions/insert/InsertJob.java | 16 +
.../doris/job/extensions/insert/InsertTask.java | 6 +-
.../apache/doris/job/extensions/mtmv/MTMVJob.java | 4 +
.../apache/doris/job/extensions/mtmv/MTMVTask.java | 24 +-
.../java/org/apache/doris/journal/Journal.java | 6 +
.../org/apache/doris/journal/JournalEntity.java | 6 +
.../apache/doris/journal/bdbje/BDBJEJournal.java | 5 +
.../doris/journal/bdbje/BDBJournalCursor.java | 18 +-
.../apache/doris/journal/local/LocalJournal.java | 5 +
.../main/java/org/apache/doris/load/EtlStatus.java | 12 +
.../org/apache/doris/load/StreamLoadRecord.java | 5 +-
.../org/apache/doris/load/StreamLoadRecordMgr.java | 8 +-
.../apache/doris/load/loadv2/BrokerLoadJob.java | 5 +-
.../load/loadv2/BrokerLoadingTaskAttachment.java | 8 +-
.../apache/doris/load/loadv2/InsertLoadJob.java | 6 +-
.../java/org/apache/doris/load/loadv2/LoadJob.java | 3 +
.../apache/doris/load/loadv2/LoadLoadingTask.java | 1 +
.../org/apache/doris/load/loadv2/LoadManager.java | 6 +-
.../doris/load/routineload/KafkaTaskInfo.java | 1 +
.../doris/load/routineload/RoutineLoadJob.java | 4 +
.../java/org/apache/doris/master/Checkpoint.java | 16 +
.../java/org/apache/doris/master/MasterImpl.java | 8 +-
.../java/org/apache/doris/metric/MetricRepo.java | 357 +-
.../java/org/apache/doris/mtmv/MTMVPlanUtil.java | 7 +-
.../org/apache/doris/mtmv/MTMVRelationManager.java | 2 +-
.../main/java/org/apache/doris/mtmv/MTMVUtil.java | 26 +
.../org/apache/doris/mysql/MysqlSerializer.java | 44 +-
.../org/apache/doris/mysql/privilege/Auth.java | 33 +-
.../mysql/privilege/CommonUserProperties.java | 22 +
.../apache/doris/mysql/privilege/UserProperty.java | 41 +-
.../doris/mysql/privilege/UserPropertyMgr.java | 18 +
.../org/apache/doris/nereids/NereidsPlanner.java | 31 +-
.../org/apache/doris/nereids/SqlCacheContext.java | 121 +-
.../org/apache/doris/nereids/StatementContext.java | 27 +-
.../glue/translator/PhysicalPlanTranslator.java | 200 +-
.../doris/nereids/jobs/executor/Rewriter.java | 2 +
.../doris/nereids/load/NereidsDataDescription.java | 12 +-
.../nereids/load/NereidsLoadScanProvider.java | 99 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 77 +-
.../post/ProjectAggregateExpressionsForCse.java | 18 +-
.../post/materialize/MaterializeProbeVisitor.java | 15 +-
.../org/apache/doris/nereids/rules/RuleType.java | 1 +
.../doris/nereids/rules/analysis/BindRelation.java | 78 +-
.../doris/nereids/rules/analysis/BindSink.java | 4 +-
.../nereids/rules/analysis/ExpressionAnalyzer.java | 39 +-
.../rules/analysis/FoldConstantForSqlCache.java | 98 +
.../mv/AbstractMaterializedViewRule.java | 15 +-
.../mv/InitMaterializationContextHook.java | 6 +-
.../exploration/mv/MaterializationContext.java | 13 +
.../mv/PreMaterializedViewRewriter.java | 1 +
.../nereids/rules/expression/check/CheckCast.java | 28 +-
.../rules/expression/rules/PartitionPruner.java | 18 +
.../rules/SimplifyComparisonPredicate.java | 78 +-
.../rules/rewrite/DistinctAggStrategySelector.java | 21 +-
.../LogicalResultSinkToShortCircuitPointQuery.java | 4 +-
.../rewrite/PushDownFilterIntoSchemaScan.java | 2 +-
.../rewrite/PushDownVectorTopNIntoOlapScan.java | 4 +-
.../PushDownVirtualColumnsIntoOlapScan.java | 11 +-
.../rules/rewrite/SplitMultiDistinctStrategy.java | 6 -
.../doris/nereids/stats/ExpressionEstimation.java | 19 +-
.../doris/nereids/stats/FilterEstimation.java | 24 +
.../doris/nereids/stats/StatsCalculator.java | 3 +-
.../doris/nereids/trees/expressions/Cast.java | 19 +-
.../nereids/trees/expressions/Placeholder.java | 4 +-
.../functions/ComputeSignatureHelper.java | 9 +-
.../expressions/functions/SearchSignature.java | 2 +-
.../executable/DateTimeExtractAndTransform.java | 22 +-
.../functions/executable/NumericArithmetic.java | 5 +-
.../functions/executable/TimeRoundSeries.java | 369 +--
.../trees/expressions/functions/scalar/Array.java | 4 +-
.../expressions/functions/scalar/Coalesce.java | 82 +-
.../expressions/functions/scalar/ConvertTz.java | 9 +-
.../trees/expressions/functions/scalar/Date.java | 4 +-
.../expressions/functions/scalar/DateFormat.java | 11 +-
.../expressions/functions/scalar/DateTrunc.java | 5 +-
.../trees/expressions/functions/scalar/DateV2.java | 5 +-
.../expressions/functions/scalar/DayCeil.java | 12 +-
.../expressions/functions/scalar/DayFloor.java | 12 +-
.../expressions/functions/scalar/FromDays.java | 4 +-
.../functions/scalar/FromIso8601Date.java | 5 +-
.../functions/scalar/FromMicrosecond.java | 5 +-
.../functions/scalar/FromMillisecond.java | 5 +-
.../expressions/functions/scalar/FromSecond.java | 5 +-
.../expressions/functions/scalar/FromUnixtime.java | 4 +-
.../expressions/functions/scalar/Greatest.java | 67 +-
.../functions/scalar/GreatestLeast.java | 83 +
.../expressions/functions/scalar/HourCeil.java | 12 +-
.../expressions/functions/scalar/HourFloor.java | 12 +-
.../trees/expressions/functions/scalar/If.java | 108 +-
.../trees/expressions/functions/scalar/Least.java | 68 +-
.../expressions/functions/scalar/MakeDate.java | 12 +-
.../functions/scalar/MapContainsEntry.java | 112 +
.../expressions/functions/scalar/MapEntries.java | 96 +
.../expressions/functions/scalar/MinuteCeil.java | 13 +-
.../expressions/functions/scalar/MinuteFloor.java | 13 +-
.../expressions/functions/scalar/MonthCeil.java | 12 +-
.../expressions/functions/scalar/MonthFloor.java | 12 +-
.../expressions/functions/scalar/NextDay.java | 5 +-
.../trees/expressions/functions/scalar/NullIf.java | 67 +-
.../trees/expressions/functions/scalar/Nvl.java | 67 +-
.../functions/scalar/PreparePlaceholder.java | 73 -
.../expressions/functions/scalar/QuarterCeil.java | 4 +-
.../expressions/functions/scalar/QuarterFloor.java | 5 +-
.../expressions/functions/scalar/SecondCeil.java | 12 +-
.../expressions/functions/scalar/SecondFloor.java | 12 +-
.../expressions/functions/scalar/StrToDate.java | 4 +-
.../trees/expressions/functions/scalar/ToDate.java | 4 +-
.../expressions/functions/scalar/ToDateV2.java | 4 +-
.../trees/expressions/functions/scalar/ToJson.java | 18 +
.../functions/scalar/UnixTimestamp.java | 28 +-
.../expressions/functions/scalar/WeekCeil.java | 13 +-
.../expressions/functions/scalar/WeekFloor.java | 13 +-
.../expressions/functions/scalar/YearCeil.java | 13 +-
.../expressions/functions/scalar/YearFloor.java | 13 +-
.../trees/expressions/literal/LargeIntLiteral.java | 8 +
.../nereids/trees/expressions/literal/Literal.java | 4 +-
.../expressions/literal/VarBinaryLiteral.java | 150 +
.../expressions/visitor/ExpressionVisitor.java | 5 +
.../expressions/visitor/ScalarFunctionVisitor.java | 15 +-
.../apache/doris/nereids/trees/plans/PlanType.java | 5 +
.../trees/plans/PrepareCommandPlanner.java} | 41 +-
.../AdminBackupClusterSnapshotCommand.java | 110 +
.../commands/AdminDropClusterSnapshotCommand.java | 108 +
.../commands/AdminSetClusterSnapshotCommand.java | 154 +
.../commands/AdminShowClusterSnapshotCommand.java | 126 +
.../AdminShowClusterSnapshotPropertiesCommand.java | 110 +
.../trees/plans/commands/CreateMTMVCommand.java | 6 +-
.../trees/plans/commands/CreatePolicyCommand.java | 42 +-
.../plans/commands/CreateStorageVaultCommand.java | 2 +-
.../trees/plans/commands/CreateTableCommand.java | 80 +-
.../trees/plans/commands/ExecuteCommand.java | 8 +
.../trees/plans/commands/ExplainCommand.java | 7 +
.../trees/plans/commands/ShowLoadCommand.java | 4 +-
.../plans/commands/ShowProcessListCommand.java | 2 +-
.../plans/commands/ShowUserPropertyCommand.java | 6 +-
.../commands/alter/AlterRepositoryCommand.java | 23 +-
.../trees/plans/commands/info/CopyIntoInfo.java | 5 +-
.../trees/plans/commands/info/CreateMTMVInfo.java | 143 +-
.../plans/commands/info/CreateResourceInfo.java | 4 +-
.../trees/plans/commands/info/CreateTableInfo.java | 218 +-
.../plans/commands/info/FixedRangePartition.java | 8 +
.../trees/plans/commands/info/InPartition.java | 4 +
.../trees/plans/commands/info/IndexDefinition.java | 3 +-
.../plans/commands/info/LessThanPartition.java | 4 +
.../plans/commands/info/PartitionDefinition.java | 32 +
.../plans/commands/info/PartitionTableInfo.java | 4 +
.../plans/commands/info/ReplacePartitionOp.java | 3 +-
.../plans/commands/info/RollupDefinition.java | 21 +
.../plans/commands/info/SetUserPropertyVarOp.java | 2 +
.../trees/plans/commands/info/TableRefInfo.java | 40 +-
.../insert/BaseExternalTableInsertExecutor.java | 6 +
.../commands/insert/InsertIntoTableCommand.java | 1 +
.../insert/InsertOverwriteTableCommand.java | 1 +
.../trees/plans/commands/insert/InsertUtils.java | 37 +-
.../plans/commands/insert/JdbcInsertExecutor.java | 6 +
.../insert/OlapGroupCommitInsertExecutor.java | 6 +
.../plans/commands/insert/OlapInsertExecutor.java | 9 +-
.../trees/plans/distribute/DistributePlanner.java | 3 +-
.../distribute/worker/job/BucketScanSource.java | 24 +
.../job/UnassignedScanBucketOlapTableJob.java | 101 +-
.../trees/plans/logical/LogicalSetOperation.java | 14 +
.../plans/physical/PhysicalOneRowRelation.java | 13 +
.../trees/plans/visitor/CommandVisitor.java | 30 +
.../apache/doris/nereids/types/AggStateType.java | 8 +
.../org/apache/doris/nereids/types/BigIntType.java | 5 +
.../org/apache/doris/nereids/types/DataType.java | 11 +
.../apache/doris/nereids/types/DecimalV3Type.java | 17 +-
.../apache/doris/nereids/types/IntegerType.java | 5 +
.../apache/doris/nereids/types/LargeIntType.java | 5 +
.../apache/doris/nereids/types/SmallIntType.java | 5 +
.../apache/doris/nereids/types/TinyIntType.java | 5 +
.../apache/doris/nereids/types/VarBinaryType.java | 103 +
.../doris/nereids/types/coercion/IntegralType.java | 7 +
.../doris/nereids/util/MoreFieldsThread.java | 31 +
.../doris/nereids/util/TypeCoercionUtils.java | 511 ++-
.../java/org/apache/doris/persist/EditLog.java | 10 +
.../apache/doris/persist/GlobalVarPersistInfo.java | 5 +
.../org/apache/doris/persist/OperationType.java | 2 +
.../planner/BackendPartitionedSchemaScanNode.java | 1 +
.../apache/doris/planner/GroupCommitPlanner.java | 11 +
.../org/apache/doris/planner/SchemaScanNode.java | 18 +-
.../org/apache/doris/policy/StoragePolicy.java | 2 +-
.../java/org/apache/doris/qe/ConnectContext.java | 15 +-
.../java/org/apache/doris/qe/ConnectProcessor.java | 10 +
.../main/java/org/apache/doris/qe/Coordinator.java | 9 +
.../main/java/org/apache/doris/qe/DdlExecutor.java | 54 -
.../java/org/apache/doris/qe/GlobalVariable.java | 26 +-
.../main/java/org/apache/doris/qe/LoadContext.java | 9 +
.../org/apache/doris/qe/NereidsCoordinator.java | 5 +
.../java/org/apache/doris/qe/SessionVariable.java | 165 +-
.../main/java/org/apache/doris/qe/SetExecutor.java | 70 -
.../java/org/apache/doris/qe/StmtExecutor.java | 141 +-
.../main/java/org/apache/doris/qe/VariableMgr.java | 14 +-
.../org/apache/doris/qe/cache/CacheAnalyzer.java | 34 +-
.../java/org/apache/doris/qe/cache/SqlCache.java | 4 +-
.../org/apache/doris/qe/runtime/LoadProcessor.java | 3 +
.../WorkloadActionSetSessionVar.java | 14 +-
.../org/apache/doris/rpc/BackendServiceProxy.java | 33 -
.../apache/doris/service/FrontendServiceImpl.java | 31 +-
.../apache/doris/statistics/AnalysisManager.java | 33 +-
.../doris/statistics/AnalysisTaskWrapper.java | 8 +
.../apache/doris/statistics/BaseAnalysisTask.java | 4 +
.../statistics/StatisticsMetricCollector.java | 138 +
.../doris/statistics/util/StatisticsUtil.java | 3 +-
.../ExternalFileTableValuedFunction.java | 14 +-
.../doris/tablefunction/MetadataGenerator.java | 67 +
.../java/org/apache/doris/task/AgentClient.java | 61 -
.../apache/doris/task/PushStoragePolicyTask.java | 2 +-
.../doris/transaction/DatabaseTransactionMgr.java | 59 +-
.../org/apache/doris/analysis/AccessTestUtil.java | 2 +-
.../org/apache/doris/backup/BackupJobTest.java | 98 +-
.../org/apache/doris/catalog/S3ResourceTest.java | 2 +-
.../org/apache/doris/catalog/SchemaTableTest.java | 96 +
.../org/apache/doris/catalog/UserPropertyTest.java | 4 +
.../doris/cloud/catalog/HdfsStorageVaultTest.java | 2 +-
.../cloud/datasource/CloudInternalCatalogTest.java | 819 -----
.../org/apache/doris/common/GenericPoolTest.java | 35 -
.../doris/common/profile/SummaryProfileTest.java | 63 +
.../doris/datasource/InternalCatalogTest.java | 600 ----
.../doris/datasource/hive/HiveMetadataOpsTest.java | 170 -
.../property/constants/AzurePropertiesTest.java | 55 -
.../AWSGlueMetaStoreBasePropertiesTest.java | 111 +
.../metastore/AWSGlueMetaStorePropertiesTest.java | 174 -
.../metastore/AbstractIcebergPropertiesTest.java | 125 +
.../property/metastore/GlueCatalogTest.java | 7 +-
.../HMSAliyunDLFMetaStorePropertiesTest.java | 51 +
.../metastore/HMSGlueMetaStorePropertiesTest.java | 2 +-
.../IcebergAliyunDLFMetaStorePropertiesTest.java | 106 +
.../IcebergFileSystemMetaStorePropertiesTest.java | 69 +
.../IcebergGlueMetaStorePropertiesTest.java | 66 +
.../IcebergHMSMetaStorePropertiesTest.java | 69 +
.../IcebergS3TablesMetaStorePropertiesTest.java | 59 +
.../PaimonAliyunDLFMetaStorePropertiesTest.java | 139 +
.../property/metastore/PaimonCatalogTest.java | 5 +-
.../PaimonFileSystemMetaStorePropertiesTest.java | 63 +
.../PaimonHMSMetaStorePropertiesTest.java | 65 +
.../property/storage/COSPropertiesTest.java | 15 +
.../property/storage/GCSPropertiesTest.java | 14 +
.../property/storage/OBSPropertyTest.java | 15 +
.../property/storage/OSSPropertiesTest.java | 15 +
.../property/storage/S3PropertiesTest.java | 10 +
.../tvf/source/MetadataScanNodeTest.java | 166 +
.../apache/doris/external/hms/HmsCatalogTest.java | 5 +
.../apache/doris/fs/obj/AzureObjStorageTest.java | 2 +-
.../org/apache/doris/fs/obj/S3FileSystemTest.java | 2 +-
.../doris/fs/obj/S3ObjStorageGlobListTest.java | 2 +-
.../doris/load/loadv2/InsertLoadJobTest.java | 2 +-
.../apache/doris/load/loadv2/LoadManagerTest.java | 8 +-
.../java/org/apache/doris/metric/MetricsTest.java | 105 +
.../doris/mysql/privilege/SetPasswordTest.java | 29 +-
.../glue/translator/CountStarSmallestSlotTest.java | 460 +++
.../mv/PreMaterializedViewRewriterTest.java | 17 +
.../nereids/parser/VarBinaryLiteralParserTest.java | 175 +
.../postprocess/TopnLazyMaterializeTest.java | 27 +
.../doris/nereids/properties/UniqueTest.java | 4 +-
.../nereids/rules/analysis/BindRelationTest.java | 32 +
.../rules/SimplifyComparisonPredicateTest.java | 146 +-
.../rules/SimplifyConditionalFunctionTest.java | 10 +-
.../PushDownVirtualColumnsIntoOlapScanTest.java | 57 +
.../doris/nereids/stats/FilterEstimationTest.java | 15 +
.../doris/nereids/stats/StatsCalculatorTest.java | 2 +-
.../trees/expressions/VarBinaryLiteralTest.java | 103 +
.../executable/NumericArithmeticTest.java | 47 +
.../expressions/literal/LargeIntLiteralTest.java | 39 +
.../expressions/literal/VarBinaryLiteralTest.java | 110 +
.../trees/plans/CreateTableCommandTest.java | 183 +
.../AdminBackupClusterSnapshotCommandTest.java | 123 +
.../AdminDropClusterSnapshotCommandTest.java | 119 +
.../AdminSetClusterSnapshotCommandTest.java | 154 +
.../AdminShowClusterSnapshotCommandTest.java | 101 +
...inShowClusterSnapshotPropertiesCommandTest.java | 101 +
.../trees/plans/commands/LoadCommandTest.java | 42 +
.../doris/nereids/types/VarBinaryTypeTest.java | 88 +
.../doris/nereids/util/TypeCoercionMatrixTest.java | 1272 +++++++
.../doris/nereids/util/TypeCoercionUtilsTest.java | 516 ---
.../apache/doris/planner/ResourceTagQueryTest.java | 2 +-
.../java/org/apache/doris/policy/PolicyTest.java | 2 +-
.../java/org/apache/doris/qe/SetExecutorTest.java | 94 -
.../java/org/apache/doris/qe/SqlCacheTest.java | 7 +-
.../org/apache/doris/rewrite/FEFunctionsTest.java | 4 +-
.../doris/statistics/AnalysisManagerTest.java | 4 +-
.../apache/doris/utframe/MockedBackendFactory.java | 33 -
gensrc/proto/cloud.proto | 31 +-
gensrc/proto/internal_service.proto | 2 +
gensrc/proto/olap_file.proto | 4 +
gensrc/proto/types.proto | 1 +
gensrc/script/Makefile | 4 +-
gensrc/script/gen_build_version.sh | 2 +-
gensrc/thrift/BackendService.thrift | 26 +-
gensrc/thrift/Descriptors.thrift | 5 +-
gensrc/thrift/Exprs.thrift | 6 +
gensrc/thrift/FrontendService.thrift | 15 +-
gensrc/thrift/PaloInternalService.thrift | 186 +-
gensrc/thrift/PlanNodes.thrift | 2 +-
gensrc/thrift/Types.thrift | 8 +-
regression-test/conf/regression-conf.groovy | 4 +
.../data/ann_index_p0/cast_string_as_array.out | Bin 0 -> 363 bytes
.../scalar_quantization.out} | Bin 157 -> 143 bytes
.../cast_between_datetime.out} | Bin 171 -> 143 bytes
regression-test/data/cast_p0/cast_to_datetime.out | Bin 5783 -> 5755 bytes
regression-test/data/cast_p0/cast_to_time.out | Bin 2784 -> 2951 bytes
.../no_warmup/test_enable_prefer_cached_rowset.out | Bin 0 -> 586 bytes
.../no_warmup/test_query_freshness_tolerance.out | Bin 0 -> 446 bytes
...st_warmup_delay_compaction_query_tolerance.out} | Bin 157 -> 136 bytes
.../test_warmup_delay_idx_query_tolerance.out | Bin 0 -> 264 bytes
.../test_warmup_delay_sc_query_tolerance.out} | Bin 157 -> 181 bytes
...up_delay_timeout_compaction_query_tolerance.out | Bin 0 -> 262 bytes
.../warmup/test_warmup_download_fail.out} | Bin 157 -> 140 bytes
.../test_from_millisecond_microsecond.out | Bin 5001 -> 4619 bytes
.../data/correctness/test_str_to_date.out | Bin 757 -> 586 bytes
.../data/correctness_p0/test_select_constant.out | Bin 214 -> 216 bytes
.../data/correctness_p0/test_time_round.out | Bin 7106 -> 6940 bytes
.../data/datatype_p0/date/test_from_unixtime.out | Bin 681 -> 585 bytes
.../test_nested_types_insert_into_with_s3.out | Bin 5559373 -> 5499966
bytes
.../get_assignment_compatible_type.out | Bin 753 -> 767 bytes
.../test_create_view_nereids.out | Bin 18763 -> 19317 bytes
.../data/ddl_p0/test_alter_view_nereids.out | Bin 1051 -> 1076 bytes
.../data/doc/sql-manual/ArrayNullsafe.out | Bin 8344 -> 8377 bytes
.../sql-functions/doc_date_functions_test.out | Bin 0 -> 17611 bytes
.../hive/test_hive_basic_type.out | Bin 4557909 -> 4557891
bytes
.../hive/test_hive_get_schema_from_table.out | Bin 45855 -> 83101 bytes
.../data/external_table_p0/hive/test_hive_orc.out | Bin 357273 -> 624091
bytes
.../iceberg/test_iceberg_optimize_count.out | Bin 245 -> 313 bytes
.../jdbc/test_doris_jdbc_catalog.out | Bin 3724 -> 3695 bytes
.../jdbc/test_jdbc_query_mysql.out | Bin 82549 -> 82496 bytes
.../external_table_p0/jdbc/test_jdbc_query_tvf.out | Bin 2354 -> 2372 bytes
.../jdbc/test_mysql_jdbc_catalog.out | Bin 24751 -> 24345 bytes
.../type_test/ctas/test_mysql_all_types_ctas.out | Bin 91700 -> 91466 bytes
.../select/test_mysql_all_types_select.out | Bin 94289 -> 94636 bytes
.../type_test/tvf/test_mysql_all_types_tvf.out | Bin 6215 -> 6251 bytes
.../external_table_p0/paimon/test_paimon_gcs.out | Bin 0 -> 665 bytes
.../external_table_p0/tvf/test_file_tvf_hdfs.out | Bin 40945 -> 40964 bytes
.../data/external_table_p0/tvf/test_hdfs_tvf.out | Bin 41176 -> 41195 bytes
.../paimon/test_paimon_hms_catalog.out | Bin 2143 -> 3483 bytes
.../data/function_p0/test_math_function.out | Bin 449 -> 1486 bytes
regression-test/data/insert_p0/insert.out | Bin 15882 -> 16004 bytes
.../insert_group_commit_into_max_filter_ratio.out | Bin 297 -> 290 bytes
.../test_inverted_index_storage_format_upgrade.out | Bin 1241 -> 0 bytes
.../data/jsonb_p0/test_json_to_json.out | Bin 2295 -> 2791 bytes
.../broker_load/test_broker_load_with_negtive.out | Bin 0 -> 578 bytes
.../test_s3_load_with_set.out} | Bin 157 -> 224 bytes
.../http_stream/test_group_commit_http_stream.out | Bin 260 -> 284 bytes
.../test_insert_strict_mode_and_filter_ratio.out | Bin 0 -> 1104 bytes
.../data/load_p0/load_ddl/full_columns_data.csv | 0
.../load_ddl/test_load_ddl_hidden_column.csv | 1 +
.../test_load_ddl_hidden_column_with_func.csv | 1 +
.../load_ddl/test_load_ddl_unavaliable_column.csv | 1 +
.../load_p0/mysql_load/test_decimal_overflow.csv | 10 +
...est_mysql_load_strict_mode_and_filter_ratio.out | Bin 0 -> 1427 bytes
.../data/load_p0/mysql_load/test_no_partition.csv | 10 +
.../data/load_p0/mysql_load/test_not_number.csv | 10 +
.../data/load_p0/mysql_load/test_null_number.csv | 10 +
...t_routine_load_strict_mode_and_filter_ratio.out | Bin 0 -> 473 bytes
.../load_p0/stream_load/chinese_col_complex.csv | 3 +
.../stream_load/load_json_null_to_nullable.out | Bin 157 -> 150 bytes
.../data/load_p0/stream_load/test_bitmap.csv | 1 +
.../data/load_p0/stream_load/test_char.json | 2 +-
.../load_p0/stream_load/test_decimal_overflow.csv | 10 +
.../stream_load/test_map_load_and_function.out | Bin 23868 -> 39200 bytes
.../data/load_p0/stream_load/test_no_partition.csv | 10 +
.../data/load_p0/stream_load/test_not_number.csv | 10 +
.../data/load_p0/stream_load/test_null_number.csv | 10 +
.../stream_load/test_stream_load_bitmap.out} | Bin 171 -> 115 bytes
...st_stream_load_strict_mode_and_filter_ratio.out | Bin 0 -> 1427 bytes
..._nullable.out => test_stream_load_with_set.out} | Bin 157 -> 113 bytes
.../data/load_p0/tvf/test_tvf_error_data.out | Bin 0 -> 629 bytes
.../tvf/test_tvf_strict_mode_and_filter_ratio.out | Bin 0 -> 983 bytes
.../test_base_alter_col_type_multi_level_mtmv.out | Bin 452 -> 445 bytes
.../test_base_drop_col_multi_level_mtmv.out | Bin 428 -> 421 bytes
.../mtmv_p0/test_base_drop_multi_level_mtmv.out | Bin 400 -> 393 bytes
.../test_base_rename_col_multi_level_mtmv.out | Bin 436 -> 429 bytes
.../mtmv_p0/test_base_rename_multi_level_mtmv.out | Bin 408 -> 401 bytes
.../mtmv_p0/test_base_replace_multi_level_mtmv.out | Bin 1075 -> 1061 bytes
.../data/mtmv_p0/test_multi_level_mtmv.out | Bin 445 -> 438 bytes
.../array/test_array_char(255).csv | 4 +-
.../array/test_array_double.csv | 2 +-
.../array/test_array_varchar(65535).csv | 2 +-
.../test_array_varchar(65535)_hive_serde_res.csv | 2 +-
.../data/nereids_function_p0/scalar_function/S.out | Bin 53858 -> 53416 bytes
.../data/nereids_function_p0/scalar_function/U.out | Bin 2752 -> 2418 bytes
.../data/nereids_function_p0/type_coercion.out | Bin 732 -> 727 bytes
.../nereids_p0/ddl/show_view/show_view_command.out | Bin 1995 -> 2071 bytes
.../nereids_p0/insert_into_table/insert_values.out | Bin 2606 -> 2613 bytes
.../operator/test_arithmetic_operators.out | Bin 8249 -> 7894 bytes
.../data/nereids_p0/show/test_show_create_view.out | Bin 763 -> 837 bytes
.../conditional_functions/test_coalesce.out | Bin 8653 -> 8613 bytes
.../test_conditional_function.out | Bin 2498 -> 2682 bytes
.../conditional_functions/test_nullif.out | Bin 4252 -> 4248 bytes
.../datetime_functions/test_date_function.out | Bin 11069 -> 10701 bytes
.../stats/col_stats/hot_value_str_to_date.out | Bin 0 -> 245 bytes
.../data/nereids_p0/union/test_union.out | Bin 13835 -> 13923 bytes
.../nereids_rules_p0/eager_aggregate/basic.out | Bin 3111 -> 3201 bytes
.../eager_aggregate/basic_one_side.out | Bin 3131 -> 3221 bytes
...simplify_comparison_predicate_int_vs_double.out | Bin 0 -> 6124 bytes
.../filter_push_down/push_filter_through.out | Bin 9740 -> 9770 bytes
.../extend_infer_equal_predicate.out | Bin 30311 -> 30295 bytes
.../infer_predicate/infer_intersect_except.out | Bin 4358 -> 4328 bytes
.../infer_predicate/pull_up_predicate_literal.out | Bin 72316 -> 69355 bytes
.../infer_predicate/pull_up_predicate_set_op.out | Bin 19686 -> 19725 bytes
.../max_min_filter_push_down.out | Bin 5969 -> 5984 bytes
.../mv/date_trunc/mv_with_date_trunc.out | Bin 4420 -> 4378 bytes
.../union_all_compensate/union_all_compensate.out | Bin 1287 -> 2103 bytes
.../union_rewrite_grace_big.out | Bin 4063 -> 6417 bytes
.../data/nereids_rules_p0/pkfk/eliminate_inner.out | Bin 6967 -> 7072 bytes
.../pull_up_join_from_union.out | Bin 5762 -> 5777 bytes
.../simplify_conditional_function.out | Bin 1229 -> 1223 bytes
.../unique_function/agg_with_unique_function.out | Bin 13561 -> 13017 bytes
.../data/nereids_syntax_p0/agg_4_phase.out | Bin 245 -> 316 bytes
.../data/nereids_syntax_p0/set_operation.out | Bin 3623 -> 3619 bytes
.../sql/test_compare_expression.out | Bin 898 -> 784 bytes
.../test_arithmetic_operators.out | Bin 8249 -> 7894 bytes
.../data/prepared_stmt_p0/prepared_stmt.out | Bin 5389 -> 5414 bytes
regression-test/data/query_p0/cache/sql_cache.out | Bin 669 -> 837 bytes
.../query_p0/cast/test_complextype_to_json.out | Bin 1410 -> 1464 bytes
.../operator/test_arithmetic_operators.out | Bin 3289 -> 3193 bytes
.../schema_table/test_sql_block_rule_status.out | Bin 0 -> 270 bytes
.../sql_functions/array_functions/sql/q02.out | Bin 2827 -> 2826 bytes
.../array_functions/test_array_functions.out | Bin 29126 -> 29072 bytes
.../test_array_functions_by_literal.out | Bin 30224 -> 30210 bytes
.../test_array_functions_with_where.out | Bin 1869 -> 1863 bytes
.../conditional_functions/test_coalesce.out | Bin 8649 -> 8613 bytes
.../test_conditional_function.out | Bin 4260 -> 3283 bytes
.../conditional_functions/test_json_parse.out | Bin 1066 -> 1666 bytes
.../conditional_functions/test_nullif.out | Bin 4280 -> 4276 bytes
.../datetime_functions/test_date_floor_ceil.out | Bin 5624 -> 6504 bytes
.../datetime_functions/test_date_function.out | Bin 10819 -> 10539 bytes
.../datetime_functions/test_from_iso8601_date.out | Bin 2676 -> 1925 bytes
.../ip_functions/test_is_ip_string_functions.out | Bin 171 -> 550 bytes
.../sql_functions/json_functions/json_search.out | Bin 6323 -> 7471 bytes
.../json_functions/test_json_exists_path.out | Bin 0 -> 1132 bytes
.../json_functions/test_json_extract.out | Bin 1893 -> 2936 bytes
.../json_functions/test_json_function.out | Bin 2996 -> 3586 bytes
.../sql_functions/math_functions/test_round.out | Bin 5553 -> 5583 bytes
.../query_p0/topn_lazy/topn_lazy_on_data_model.out | Bin 1272 -> 2130 bytes
regression-test/data/query_p0/union/test_union.out | Bin 13835 -> 13923 bytes
.../test_schema_change_with_empty_rowset.out} | Bin 157 -> 116 bytes
.../tpcds_sf100/constraints/query23.out | Bin 4992 -> 4986 bytes
.../tpcds_sf100/noStatsRfPrune/query1.out | Bin 2031 -> 2025 bytes
.../tpcds_sf100/noStatsRfPrune/query14.out | Bin 10059 -> 9921 bytes
.../tpcds_sf100/noStatsRfPrune/query23.out | Bin 4787 -> 4781 bytes
.../tpcds_sf100/noStatsRfPrune/query24.out | Bin 3122 -> 3116 bytes
.../tpcds_sf100/noStatsRfPrune/query30.out | Bin 3113 -> 3107 bytes
.../tpcds_sf100/noStatsRfPrune/query44.out | Bin 4889 -> 4877 bytes
.../tpcds_sf100/noStatsRfPrune/query58.out | Bin 7035 -> 7071 bytes
.../tpcds_sf100/noStatsRfPrune/query65.out | Bin 2774 -> 2771 bytes
.../tpcds_sf100/noStatsRfPrune/query72.out | Bin 4354 -> 4381 bytes
.../tpcds_sf100/noStatsRfPrune/query81.out | Bin 3069 -> 3063 bytes
.../tpcds_sf100/no_stats_shape/query1.out | Bin 2155 -> 2149 bytes
.../tpcds_sf100/no_stats_shape/query14.out | Bin 10693 -> 10555 bytes
.../tpcds_sf100/no_stats_shape/query23.out | Bin 4964 -> 4958 bytes
.../tpcds_sf100/no_stats_shape/query24.out | Bin 3278 -> 3272 bytes
.../tpcds_sf100/no_stats_shape/query30.out | Bin 3272 -> 3266 bytes
.../tpcds_sf100/no_stats_shape/query44.out | Bin 4889 -> 4877 bytes
.../tpcds_sf100/no_stats_shape/query58.out | Bin 7077 -> 7113 bytes
.../tpcds_sf100/no_stats_shape/query65.out | Bin 2860 -> 2857 bytes
.../tpcds_sf100/no_stats_shape/query72.out | Bin 4556 -> 4583 bytes
.../tpcds_sf100/no_stats_shape/query81.out | Bin 3228 -> 3222 bytes
.../shape_check/tpcds_sf100/rf_prune/query1.out | Bin 2103 -> 2097 bytes
.../shape_check/tpcds_sf100/rf_prune/query14.out | Bin 10129 -> 9991 bytes
.../shape_check/tpcds_sf100/rf_prune/query23.out | Bin 4974 -> 4968 bytes
.../shape_check/tpcds_sf100/rf_prune/query24.out | Bin 3122 -> 3116 bytes
.../shape_check/tpcds_sf100/rf_prune/query30.out | Bin 3239 -> 3233 bytes
.../shape_check/tpcds_sf100/rf_prune/query44.out | Bin 4689 -> 4677 bytes
.../shape_check/tpcds_sf100/rf_prune/query58.out | Bin 7152 -> 7188 bytes
.../shape_check/tpcds_sf100/rf_prune/query65.out | Bin 2916 -> 2913 bytes
.../shape_check/tpcds_sf100/rf_prune/query81.out | Bin 3061 -> 3055 bytes
.../data/shape_check/tpcds_sf100/shape/query1.out | Bin 2176 -> 2170 bytes
.../data/shape_check/tpcds_sf100/shape/query14.out | Bin 10603 -> 10465 bytes
.../data/shape_check/tpcds_sf100/shape/query23.out | Bin 5016 -> 5010 bytes
.../data/shape_check/tpcds_sf100/shape/query24.out | Bin 3277 -> 3271 bytes
.../data/shape_check/tpcds_sf100/shape/query30.out | Bin 3291 -> 3285 bytes
.../data/shape_check/tpcds_sf100/shape/query44.out | Bin 4689 -> 4677 bytes
.../data/shape_check/tpcds_sf100/shape/query58.out | Bin 7194 -> 7230 bytes
.../data/shape_check/tpcds_sf100/shape/query65.out | Bin 3002 -> 2999 bytes
.../data/shape_check/tpcds_sf100/shape/query81.out | Bin 3220 -> 3214 bytes
.../tpcds_sf1000/bs_downgrade_shape/query44.out | Bin 4683 -> 4671 bytes
.../data/shape_check/tpcds_sf1000/hint/query1.out | Bin 2259 -> 2253 bytes
.../data/shape_check/tpcds_sf1000/hint/query14.out | Bin 10758 -> 10620 bytes
.../data/shape_check/tpcds_sf1000/hint/query23.out | Bin 5016 -> 5010 bytes
.../data/shape_check/tpcds_sf1000/hint/query24.out | Bin 3433 -> 3427 bytes
.../data/shape_check/tpcds_sf1000/hint/query30.out | Bin 3411 -> 3405 bytes
.../data/shape_check/tpcds_sf1000/hint/query44.out | Bin 4761 -> 4749 bytes
.../data/shape_check/tpcds_sf1000/hint/query58.out | Bin 7213 -> 7249 bytes
.../data/shape_check/tpcds_sf1000/hint/query65.out | Bin 3240 -> 3237 bytes
.../data/shape_check/tpcds_sf1000/hint/query81.out | Bin 3359 -> 3353 bytes
.../data/shape_check/tpcds_sf1000/shape/query1.out | Bin 2178 -> 2172 bytes
.../shape_check/tpcds_sf1000/shape/query14.out | Bin 10599 -> 10461 bytes
.../shape_check/tpcds_sf1000/shape/query23.out | Bin 5016 -> 5010 bytes
.../shape_check/tpcds_sf1000/shape/query24.out | Bin 3282 -> 3276 bytes
.../shape_check/tpcds_sf1000/shape/query30.out | Bin 3272 -> 3266 bytes
.../shape_check/tpcds_sf1000/shape/query44.out | Bin 4683 -> 4671 bytes
.../shape_check/tpcds_sf1000/shape/query58.out | Bin 7194 -> 7230 bytes
.../shape_check/tpcds_sf1000/shape/query65.out | Bin 3002 -> 2999 bytes
.../shape_check/tpcds_sf1000/shape/query81.out | Bin 3220 -> 3214 bytes
.../shape_check/tpcds_sf10t_orc/shape/query1.out | Bin 2155 -> 2149 bytes
.../shape_check/tpcds_sf10t_orc/shape/query14.out | Bin 10621 -> 10483 bytes
.../shape_check/tpcds_sf10t_orc/shape/query23.out | Bin 5273 -> 5267 bytes
.../shape_check/tpcds_sf10t_orc/shape/query24.out | Bin 3272 -> 3266 bytes
.../shape_check/tpcds_sf10t_orc/shape/query30.out | Bin 2537 -> 2531 bytes
.../shape_check/tpcds_sf10t_orc/shape/query44.out | Bin 4841 -> 4829 bytes
.../shape_check/tpcds_sf10t_orc/shape/query58.out | Bin 7077 -> 7113 bytes
.../shape_check/tpcds_sf10t_orc/shape/query65.out | Bin 2860 -> 2857 bytes
.../shape_check/tpcds_sf10t_orc/shape/query72.out | Bin 4561 -> 4588 bytes
.../shape_check/tpcds_sf10t_orc/shape/query81.out | Bin 2537 -> 2531 bytes
.../data/shape_check/tpch_sf1000/hint/q11.out | Bin 2074 -> 2068 bytes
.../tpch_sf1000/nostats_rf_prune/q11.out | Bin 2168 -> 2162 bytes
.../data/shape_check/tpch_sf1000/rf_prune/q11.out | Bin 2176 -> 2170 bytes
.../data/shape_check/tpch_sf1000/shape/q11.out | Bin 2176 -> 2170 bytes
.../shape_check/tpch_sf1000/shape_no_stats/q11.out | Bin 2168 -> 2162 bytes
.../test_show_create_table_and_views_nereids.out | Bin 6596 -> 6614 bytes
regression-test/data/tpch_sf0.1_p1/sql/cse.out | Bin 455 -> 3579 bytes
.../create_view_star_except_and_cast_to_sql.out | Bin 739 -> 763 bytes
regression-test/data/view_p0/view_p0.out | Bin 3484 -> 3590 bytes
.../regression/action/StreamLoadAction.groovy | 48 +-
.../org/apache/doris/regression/suite/Suite.groovy | 51 +-
.../apache/doris/regression/util/GlobalLock.groovy | 58 +
.../org/apache/doris/regression/util/Hdfs.groovy | 20 +-
.../apache/doris/regression/util/JdbcUtils.groovy | 42 +-
.../regression/util/RemoteFileOperator.groovy | 370 +++
.../pipeline/cloud_p0/conf/be_custom.conf | 3 +
.../pipeline/external/conf/regression-conf.groovy | 4 +
.../nonConcurrent/conf/regression-conf.groovy | 4 +
.../pipeline/p0/conf/regression-conf.groovy | 4 +
regression-test/plugins/test_helper.groovy | 2 +-
.../alter_p2/test_alter_colocate_group.groovy | 10 +-
.../ann_index_p0/cast_string_as_array.groovy | 155 +
.../suites/ann_index_p0/scalar_quantization.groovy | 60 +
.../test_backup_restore_colocate.groovy | 2 +-
.../backup_restore/test_backup_restore_hdfs.groovy | 2 +-
.../test_backup_restore_with_hdfs.groovy | 2 +-
.../test_create_and_drop_repository.groovy | 2 +-
.../bloom_filter_p0/test_bloom_filter_hit.groovy | 1 +
.../suites/cast_p0/cast_between_datetime.groovy | 29 +-
regression-test/suites/cast_p0/cast_to_time.groovy | 10 +
.../suites/ccr_syncer_p0/test_txn_insert.groovy | 4 +-
.../cache/http/test_list_cache_file.groovy | 3 +
...test_warm_up_cluster_event_schema_change.groovy | 6 +-
...test_warm_up_cluster_periodic_add_new_be.groovy | 1 +
.../cloud_p0/cache/ttl/test_ttl_lru_evict.groovy | 374 +--
.../test_enable_prefer_cached_rowset.groovy | 178 +
.../test_query_freshness_tolerance.groovy | 183 +
..._warmup_delay_compaction_query_tolerance.groovy | 316 ++
.../test_warmup_delay_idx_query_tolerance.groovy | 332 ++
.../test_warmup_delay_sc_query_tolerance.groovy | 308 ++
...delay_timeout_compaction_query_tolerance.groovy | 335 ++
.../warmup/test_warmup_download_fail.groovy} | 220 +-
.../cloud_p0/snapshot/test_snapshot_command.groovy | 55 +
.../cloud_p0/test_read_cluster_var_property.groovy | 214 ++
.../compaction_width_array_column.groovy | 8 +-
...paction_with_dup_key_max_file_size_limit.groovy | 2 +-
.../test_config_prune_delete_sign.groovy | 11 +-
...ilecache_with_base_compaction_thresthold.groovy | 56 +-
.../test_single_replica_compaction.groovy | 2 +-
.../test_from_millisecond_microsecond.groovy | 59 +-
.../suites/correctness/test_str_to_date.groovy | 41 +-
...est_colocate_join_with_different_tablets.groovy | 3479 ++++++++++++++++++++
.../test_ctas_mv/test_ctas_mv.groovy | 2 +
.../test_inlineview_with_project.groovy | 2 +-
.../test_inlineview_with_window_function.groovy | 2 +
.../test_mv_case/test_mv_case.groovy | 2 +
.../test_select_with_predicate_like.groovy | 2 +
.../suites/correctness_p0/test_time_round.groovy | 158 +-
.../csv_header_p0/test_csv_with_header.groovy | 84 +-
.../datatype_p0/date/test_from_unixtime.groovy | 19 +-
.../decimalv3/test_arithmetic_expressions.groovy | 118 +
.../suites/datatype_p0/decimalv3/test_load.groovy | 3 +-
.../float/test_float_special_values.groovy | 54 +-
.../one_level_nestedtypes_with_s3data.groovy | 1 -
..._nested_types_insert_into_with_agg_table.groovy | 10 +
..._nested_types_insert_into_with_dup_table.groovy | 10 +
...sted_types_insert_into_with_unique_table.groovy | 20 +
.../nested_types/query/sql/nested_with_join.sql | 6 +-
.../test_nested_types_insert_into_with_s3.groovy | 3 +
...test_nestedtypes_csv_insert_into_with_s3.groovy | 1 +
...est_nestedtypes_json_insert_into_with_s3.groovy | 1 +
.../suites/demo_p0/test_lru_persist.groovy | 37 +-
.../sql-functions/doc_date_functions_test.groovy | 1587 +++++++++
.../manual-partitioning.md.groovy | 3 +-
.../suites/export/test_array_export.groovy | 7 +-
.../outfile/csv/test_outfile_csv_map_type.groovy | 2 +
.../parquet/test_outfile_parquet_map_type.groovy | 2 +
.../test_export_table_with_label_retry.groovy | 3 +
.../export_p0/test_outfile_orc_map_type.groovy | 2 +
.../hive/ddl/test_hive_write_type.groovy | 4 +-
.../hive/test_hive_get_schema_from_table.groovy | 22 +
.../external_table_p0/hive/test_hive_orc.groovy | 23 +
.../hive/test_hive_query_cache.groovy | 179 +-
.../iceberg/test_iceberg_optimize_count.groovy | 12 +-
.../jdbc/test_doris_jdbc_catalog.groovy | 17 +
.../jdbc/test_jdbc_query_mysql.groovy | 24 +-
.../jdbc/test_jdbc_query_pg.groovy | 30 +-
.../jdbc/test_mysql_jdbc_catalog.groovy | 4 +-
.../ctas/test_mysql_all_types_ctas.groovy | 4 +-
.../select/test_mysql_all_types_select.groovy | 7 +
.../type_test/tvf/test_mysql_all_types_tvf.groovy | 1 -
.../test_iceberg_hadoop_catalog_kerberos.groovy | 1 +
.../paimon/paimon_base_filesystem.groovy | 39 +-
.../paimon/test_paimon_catalog.groovy | 491 +--
.../paimon/test_paimon_deletion_vector_oss.groovy | 7 +-
.../paimon/test_paimon_gcs.groovy | 84 +
.../paimon/test_paimon_minio.groovy | 18 +
.../external_table_p0/paimon/test_paimon_s3.groovy | 9 +
.../tvf/test_file_tvf_hdfs.groovy | 6 +-
.../tvf/test_hdfs_parquet_group4.groovy | 4 +-
.../tvf/test_hdfs_parquet_group5.groovy | 4 +-
.../tvf/test_hdfs_parquet_group6.groovy | 6 +-
.../external_table_p0/tvf/test_hdfs_tvf.groovy | 6 +-
.../hive/test_cloud_accessible_oss.groovy | 9 +-
.../paimon/test_paimon_dlf_catalog.groovy | 10 +-
.../test_paimon_dlf_catalog_miss_dlf_param.groovy | 12 +-
.../test_paimon_dlf_catalog_new_param.groovy | 14 +-
.../paimon/test_paimon_hms_catalog.groovy | 77 +-
.../hive_on_hms_and_dlf.groovy | 62 +-
.../iceberg_on_hms_and_filesystem_and_dlf.groovy | 155 +-
.../iceberg_rest_s3_storage_vended_test.groovy | 0
.../iceberg_rest_storage_test.groovy} | 89 +-
.../test_disable_move_memtable.groovy | 4 +-
.../suites/function_p0/test_math_function.groovy | 128 +-
.../insert_p0/insert_group_commit_into.groovy | 12 +-
...nsert_group_commit_into_max_filter_ratio.groovy | 4 +-
.../suites/insert_p0/test_insert_docs_demo.groovy | 2 +-
.../test_insert_partition_fail_url.groovy | 4 +-
.../insert_p0/test_insert_strict_fail_url.groovy | 4 +-
.../suites/insert_p0/test_struct_insert.groovy | 1 +
.../insert_p0/transaction/test_txn_limit.groovy | 91 +
.../inverted_index_p0/load/test_spark_load.groovy | 3 +
...st_inverted_index_storage_format_upgrade.groovy | 409 ---
.../suites/jsonb_p0/test_json_to_json.groovy | 56 +-
.../insert/test_too_many_versions_detection.groovy | 44 +
.../test_broker_load_with_negtive.groovy | 144 +
.../load_p0/broker_load/test_etl_failed.groovy | 3 +-
.../broker_load/test_s3_load_with_set.groovy | 218 ++
.../test_group_commit_http_stream.groovy | 7 +-
.../http_stream/test_http_stream_properties.groovy | 2 +-
...test_insert_strict_mode_and_filter_ratio.groovy | 409 +++
.../data/load_ddl_basic_data_json_by_line.json | 0
.../load_p0/load_ddl/ddl/agg_tbl_basic_create.sql | 58 +
.../load_p0/load_ddl/ddl/agg_tbl_basic_drop.sql | 1 +
.../ddl/test_load_ddl_hidden_column_create.sql | 21 +
.../ddl/test_load_ddl_hidden_column_drop.sql | 1 +
.../test_load_ddl_unavaliable_column_create.sql | 19 +
.../ddl/test_load_ddl_unavaliable_column_drop.sql | 1 +
.../suites/load_p0/load_ddl/test_load_ddl.groovy | 216 ++
.../test_routine_load_advanced_mapping.groovy | 202 ++
.../test_stream_load_advanced_mapping.groovy | 327 ++
..._mysql_load_strict_mode_and_filter_ratio.groovy | 365 ++
.../routine_load/data/test_decimal_overflow.csv | 10 +
.../routine_load/data/test_no_partition.csv | 10 +
.../load_p0/routine_load/data/test_not_number.csv | 10 +
.../data/test_strict_mode_and_filter_ratio.csv | 10 +
.../load_p0/routine_load/test_black_list.groovy | 4 +
.../routine_load/test_routine_load_alter.groovy | 6 +-
...outine_load_strict_mode_and_filter_ratio.groovy | 411 +++
.../routine_load/test_routine_load_with_sc.groovy | 1 +
.../load_p0/spark_load/test_spark_load.groovy | 2 +-
.../stream_load/load_json_null_to_nullable.groovy | 15 +-
.../stream_load/test_chinese_col_load.groovy | 128 +
.../stream_load/test_map_load_and_function.groovy | 210 ++
.../test_s3_bytes_written_metrics.groovy | 80 +
.../load_p0/stream_load/test_stream_load.groovy | 1 +
.../stream_load/test_stream_load_bitmap.groovy | 54 +
...stream_load_strict_mode_and_filter_ratio.groovy | 526 +++
.../test_stream_load_with_filtered_rows.groovy | 3 +-
.../stream_load/test_stream_load_with_set.groovy | 96 +
.../load_p0/tvf/test_tvf_error_column.groovy | 164 +
.../suites/load_p0/tvf/test_tvf_error_data.groovy | 214 ++
.../test_tvf_strict_mode_and_filter_ratio.groovy | 312 ++
.../metrics_p0/test_delete_bitmap_metrics.groovy | 16 +-
...est_base_alter_col_type_multi_level_mtmv.groovy | 2 +-
.../test_base_drop_col_multi_level_mtmv.groovy | 2 +-
.../mtmv_p0/test_base_drop_multi_level_mtmv.groovy | 2 +-
.../test_base_rename_col_multi_level_mtmv.groovy | 2 +-
.../test_base_rename_multi_level_mtmv.groovy | 2 +-
.../test_base_replace_multi_level_mtmv.groovy | 2 +-
.../mtmv_p0/test_hive_empty_partition_mtmv.groovy | 81 +
.../mtmv_p0/test_mtmv_sql_cache_and_profile.groovy | 117 +-
.../suites/mv_p0/agg_table_mv/agg_table_mv.groovy | 83 +
.../mv_p0/mv_negative/agg_negative_test.groovy | 2 +
.../mv_p0/mv_negative/dup_negative_test.groovy | 2 +
.../mv_p0/mv_negative/mor_negative_test.groovy | 2 +
.../mv_p0/mv_negative/mow_negative_test.groovy | 2 +
.../suites/mv_p0/test_o2/test_o2.groovy | 2 +
.../suites/nereids_function_p0/load.groovy | 8 +-
.../nereids_function_p0/scalar_function/Map.groovy | 8 +-
.../nereids_function_p0/scalar_function/S.groovy | 20 +-
.../nereids_function_p0/scalar_function/U.groovy | 20 +-
.../cache/parse_sql_from_sql_cache.groovy | 1762 +++++-----
.../cache/prepare_stmt_with_sql_cache.groovy | 57 +-
.../suites/nereids_p0/datatype/test_cast.groovy | 6 +-
.../nereids_p0/datatype/test_compatible.groovy | 27 -
.../datatype/test_date_implicit_cast.groovy | 6 +-
.../expression/expression_depth_check.groovy | 6 +-
.../fold_constant/fold_constant_by_be.groovy | 4 +-
.../fold_constant_date_arithmatic.groovy | 13 +-
.../fold_constant/fold_constant_nullable.groovy | 2 +-
.../insert_into_table/complex_insert.groovy | 2 +
.../insert_into_table/insert_values.groovy | 7 +-
.../suites/nereids_p0/join/test_join_on.groovy | 2 +-
.../agg_state/test_outfile_agg_state.groovy | 19 +-
.../agg_state_array/test_outfile_agg_array.groovy | 17 +-
.../test_outfile_agg_state_bitmap.groovy | 17 +-
.../nereids_p0/outfile/hll/test_outfile_hll.groovy | 19 +-
.../test_outfile_quantile_state.groovy | 19 +-
.../show/test_nereids_show_load_warnings.groovy | 30 +-
.../nereids_p0/show/test_show_create_view.groovy | 8 +-
.../datetime_functions/test_date_function.groovy | 31 +-
.../stats/col_stats/hot_value_str_to_date.groovy | 60 +
.../test_select_with_predicate_like.groovy | 3 +-
.../suites/nereids_p0/union/test_union.groovy | 13 +-
.../distinct_agg_strategy_selector.groovy | 12 +
...plify_comparison_predicate_int_vs_double.groovy | 161 +
.../infer_predicate/infer_intersect_except.groovy | 9 +-
.../pull_up_predicate_literal.groovy | 18 -
.../mv/date_trunc/mv_with_date_trunc.groovy | 13 +-
.../partition_mv_rewrite.groovy | 12 +-
.../union_all_compensate.groovy | 530 +--
.../union_rewrite_grace_big.groovy | 1095 +++---
.../nereids_rules_p0/mv/variant/variant_mv.groovy | 2 +-
.../partition_prune/always_mono_func.groovy | 2 +-
.../multi_column_range_partition.groovy | 8 +-
.../partition_prune/test_convert_tz.groovy | 9 +-
...une_mono.groovy => test_date_prune_mono.groovy} | 2 +-
.../partition_prune/test_date_trunc_prune.groovy | 2 +-
.../suites/nereids_syntax_p0/agg_4_phase.groovy | 23 +
.../suites/nereids_syntax_p0/any_value.groovy | 1 +
.../suites/nereids_syntax_p0/array_function.groovy | 11 +-
.../mv/aggregate/agg_sync_mv.groovy | 2 +-
.../nereids_syntax_p0/test_cast_datetime.groovy | 2 +
.../test_simplify_comparison.groovy | 10 +-
.../mv/aggregate/agg_sync_mv.groovy | 2 +-
.../suites/nereids_tpch_p0/tpch/agg_cse.groovy | 15 +
.../test_col_data_type_boundary.groovy | 2 +
.../suites/point_query_p0/test_point_query.groovy | 2 +
regression-test/suites/postgres/load.groovy | 4 +
.../suites/prepared_stmt_p0/prepared_stmt.groovy | 31 +-
.../aggregate/aggregate_max_min_by_test.groovy | 2 +
.../suites/query_p0/cache/sql_cache.groovy | 123 +-
.../suites/query_p0/cast/test_cast.groovy | 2 +-
.../query_p0/cast/test_complextype_to_json.groovy | 31 +-
.../query_p0/operator/test_sort_operator.groovy | 2 +-
.../schema_table/test_active_queries.groovy | 6 +-
.../schema_table/test_sql_block_rule_status.groovy | 65 +
.../sql_functions/array_functions/sql/q02.sql | 2 +-
.../array_functions/test_array_functions.groovy | 2 +-
.../test_array_functions_by_literal.groovy | 10 +-
.../test_array_functions_with_where.groovy | 2 +-
.../sql_functions/conditional_functions/data.txt | 1 +
.../test_conditional_function.groovy | 188 +-
.../conditional_functions/test_json_parse.groovy | 27 +-
.../conditional_functions/test_nullif.groovy | 2 +-
.../datetime_functions/test_date_floor_ceil.groovy | 146 +-
.../datetime_functions/test_date_function.groovy | 94 +-
.../test_from_iso8601_date.groovy | 167 +-
.../test_is_ip_string_functions.groovy | 23 +-
.../json_function/test_query_json_array.groovy | 10 -
.../json_functions/json_search.groovy | 39 +-
.../json_functions/test_json_exists_path.groovy | 180 +
.../json_functions/test_json_extract.groovy | 111 +-
.../json_functions/test_json_function.groovy | 49 +-
.../sql_functions/math_functions/test_round.groovy | 17 +
.../query_p0/system/test_table_properties.groovy | 3 +
.../suites/query_p0/test_row_policy.groovy | 50 +
.../test_select_with_predicate_like.groovy | 35 -
.../suites/query_p0/topn_lazy/topn_lazy.groovy | 9 +-
.../topn_lazy/topn_lazy_on_data_model.groovy | 16 +-
.../suites/query_p0/union/test_union.groovy | 9 +-
.../return_in_advance_if_block_is_empty.groovy | 9 +-
.../suites/s3_vault/default_vault_p2/load.groovy | 8 +
.../suites/s3_vault/multi_vault_p2/load.groovy | 8 +
.../test_agg_schema_key_change_modify1.groovy | 1 +
.../test_dup_schema_key_change_modify1.groovy | 1 +
...test_schema_change_mow_with_empty_rowset.groovy | 1 +
...=> test_schema_change_with_empty_rowset.groovy} | 23 +-
.../test_schema_reordering_dup.groovy | 1 +
.../test_schema_reordering_unique.groovy | 2 +
.../test_unique_schema_key_change_modify.groovy | 1 +
.../suites/show_p0/test_show_processlist.groovy | 6 +-
regression-test/suites/ssb_sf1_p2/load.groovy | 8 +
.../statistics/test_drop_stats_and_truncate.groovy | 4 +
.../suites/tpch_sf0.1_p1/sql/cse.groovy | 11 +-
.../four/load_four_step.groovy | 2 +-
.../three/load_three_step.groovy | 2 +-
run-cloud-ut.sh | 1 +
1270 files changed, 43989 insertions(+), 16475 deletions(-)
create mode 100644
be/src/exec/schema_scanner/schema_sql_block_rule_status_scanner.cpp
create mode 100644
be/src/exec/schema_scanner/schema_sql_block_rule_status_scanner.h
create mode 100644 be/src/io/cache/file_cache_lru_tool.cpp
create mode 100644 be/src/vec/columns/column_varbinary.cpp
create mode 100644 be/src/vec/columns/column_varbinary.h
create mode 100644 be/src/vec/common/string_view.cpp
create mode 100644 be/src/vec/common/string_view.h
create mode 100644 be/src/vec/data_types/data_type_varbinary.cpp
create mode 100644 be/src/vec/data_types/data_type_varbinary.h
create mode 100644 be/src/vec/data_types/serde/data_type_varbinary_serde.cpp
copy be/src/vec/data_types/serde/{data_type_variant_serde.h =>
data_type_varbinary_serde.h} (73%)
create mode 100644 be/src/vec/functions/datetime_errors.h
delete mode 100644 be/src/vec/functions/function_convert_tz.h
delete mode 100644 be/src/vec/functions/function_date_or_datetime_to_string.h
rename be/src/vec/functions/{function_timestamp.cpp =>
function_other_types_to_date.cpp} (79%)
rename be/test/ai/{aggregate_function_llm_agg_test.cpp =>
aggregate_function_ai_agg_test.cpp} (79%)
rename be/test/ai/{build_prompt_test.cpp => ai_function_test.cpp} (93%)
create mode 100644 be/test/cloud/cloud_tablet_query_prefer_cache_test.cpp
create mode 100644 be/test/cloud/cloud_tablet_query_with_tolerance_test.cpp
rename be/test/expected_result/vec/data_types/{timev2_0_to_string.out =>
TimeV2_0_to_string.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_0_to_string_2.out =>
TimeV2_0_to_string_2.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_0_to_string_3.out =>
TimeV2_0_to_string_3.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_0_to_string_batch.out =>
TimeV2_0_to_string_batch.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_5_to_string.out =>
TimeV2_5_to_string.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_5_to_string_2.out =>
TimeV2_5_to_string_2.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_5_to_string_3.out =>
TimeV2_5_to_string_3.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_5_to_string_batch.out =>
TimeV2_5_to_string_batch.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_6_to_string.out =>
TimeV2_6_to_string.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_6_to_string_2.out =>
TimeV2_6_to_string_2.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_6_to_string_3.out =>
TimeV2_6_to_string_3.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_6_to_string_batch.out =>
TimeV2_6_to_string_batch.out} (100%)
delete mode 100644 be/test/expected_result/vec/data_types/timev2_to_string.out
delete mode 100644
be/test/expected_result/vec/data_types/timev2_to_string_2.out
delete mode 100644
be/test/expected_result/vec/data_types/timev2_to_string_3.out
delete mode 100644
be/test/expected_result/vec/data_types/timev2_to_string_batch.out
create mode 100644
be/test/olap/vector_search/ann_topn_runtime_negative_test.cpp
create mode 100644 be/test/vec/columns/column_varbinary_test.cpp
create mode 100644 be/test/vec/common/string_view_test.cpp
rename be/test/vec/data_types/{data_type_time_v2_test.cpp =>
data_type_datetime_v2_test.cpp} (96%)
create mode 100644 be/test/vec/data_types/data_type_varbinary_test.cpp
create mode 100644
be/test/vec/data_types/serde/data_type_serde_varbinary_test.cpp
delete mode 100644 be/test/vec/function/function_convert_tz_test.cpp
create mode 100644 cloud/src/recycler/recycler_snapshot.cpp
create mode 100644 cloud/src/snapshot/CMakeLists.txt
create mode 100644 cloud/src/snapshot/snapshot_manager.cpp
create mode 100644 cloud/src/snapshot/snapshot_manager.h
create mode 100644
docker/thirdparties/docker-compose/kerberos/paimon_data/hdfs_db.db/external_test_table/bucket-0/data-5414d3da-b984-4a28-a501-e7dc42a1760f-0.parquet
create mode 100644
docker/thirdparties/docker-compose/kerberos/paimon_data/hdfs_db.db/external_test_table/manifest/manifest-3224f4a3-e7f2-402a-b1b1-bd1fe57d57ad-0
create mode 100644
docker/thirdparties/docker-compose/kerberos/paimon_data/hdfs_db.db/external_test_table/manifest/manifest-list-7dbac4ab-1226-4c1f-8346-3b388de65ea3-0
create mode 100644
docker/thirdparties/docker-compose/kerberos/paimon_data/hdfs_db.db/external_test_table/manifest/manifest-list-7dbac4ab-1226-4c1f-8346-3b388de65ea3-1
create mode 100644
docker/thirdparties/docker-compose/kerberos/paimon_data/hdfs_db.db/external_test_table/schema/schema-0
copy
docker/thirdparties/docker-compose/{hive/scripts/paimon1/db1.db/append_table =>
kerberos/paimon_data/hdfs_db.db/external_test_table}/snapshot/EARLIEST (100%)
copy
docker/thirdparties/docker-compose/{hive/scripts/paimon1/db1.db/all_table_with_parquet
=> kerberos/paimon_data/hdfs_db.db/external_test_table}/snapshot/LATEST (100%)
create mode 100644
docker/thirdparties/docker-compose/kerberos/paimon_data/hdfs_db.db/external_test_table/snapshot/snapshot-1
create mode 100644
docker/thirdparties/docker-compose/kerberos/sql/create_paimon_hive_table.hql
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/SetLdapPassVar.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/SetNamesVar.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/SetPassVar.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/SetStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/SetTransaction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/SetUserPropertyVar.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/VarBinaryLiteral.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/cloud/snapshot/CloudSnapshotHandler.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/cloud/snapshot/SnapshotState.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/constants/AzureProperties.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/constants/S3Properties.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/metastore/AWSGlueMetaStoreProperties.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/metastore/DataProcProperties.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/FoldConstantForSqlCache.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/GreatestLeast.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/MapContainsEntry.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/MapEntries.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/PreparePlaceholder.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/literal/VarBinaryLiteral.java
rename
fe/fe-core/src/main/java/org/apache/doris/{datasource/property/metastore/FileMetastoreProperties.java
=> nereids/trees/plans/PrepareCommandPlanner.java} (50%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/AdminBackupClusterSnapshotCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/AdminDropClusterSnapshotCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/AdminSetClusterSnapshotCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/AdminShowClusterSnapshotCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/AdminShowClusterSnapshotPropertiesCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/types/VarBinaryType.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/qe/DdlExecutor.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/qe/SetExecutor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsMetricCollector.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/SchemaTableTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/cloud/datasource/CloudInternalCatalogTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/profile/SummaryProfileTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/InternalCatalogTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/hive/HiveMetadataOpsTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/constants/AzurePropertiesTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/AWSGlueMetaStoreBasePropertiesTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/AWSGlueMetaStorePropertiesTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/AbstractIcebergPropertiesTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/HMSAliyunDLFMetaStorePropertiesTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/IcebergAliyunDLFMetaStorePropertiesTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/IcebergFileSystemMetaStorePropertiesTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/IcebergGlueMetaStorePropertiesTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/IcebergHMSMetaStorePropertiesTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/IcebergS3TablesMetaStorePropertiesTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/PaimonAliyunDLFMetaStorePropertiesTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/PaimonFileSystemMetaStorePropertiesTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/PaimonHMSMetaStorePropertiesTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/tvf/source/MetadataScanNodeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/glue/translator/CountStarSmallestSlotTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/parser/VarBinaryLiteralParserTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/VarBinaryLiteralTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/executable/NumericArithmeticTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/literal/VarBinaryLiteralTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/AdminBackupClusterSnapshotCommandTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/AdminDropClusterSnapshotCommandTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/AdminSetClusterSnapshotCommandTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/AdminShowClusterSnapshotCommandTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/AdminShowClusterSnapshotPropertiesCommandTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/types/VarBinaryTypeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/util/TypeCoercionMatrixTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/qe/SetExecutorTest.java
create mode 100644 regression-test/data/ann_index_p0/cast_string_as_array.out
copy regression-test/data/{load_p0/stream_load/load_json_null_to_nullable.out
=> ann_index_p0/scalar_quantization.out} (61%)
copy
regression-test/data/{query_p0/sql_functions/ip_functions/test_is_ip_string_functions.out
=> cast_p0/cast_between_datetime.out} (73%)
create mode 100644
regression-test/data/cloud_p0/read_cluster_cache/no_warmup/test_enable_prefer_cached_rowset.out
create mode 100644
regression-test/data/cloud_p0/read_cluster_cache/no_warmup/test_query_freshness_tolerance.out
copy regression-test/data/{load_p0/stream_load/load_json_null_to_nullable.out
=>
cloud_p0/read_cluster_cache/warmup/test_warmup_delay_compaction_query_tolerance.out}
(61%)
create mode 100644
regression-test/data/cloud_p0/read_cluster_cache/warmup/test_warmup_delay_idx_query_tolerance.out
copy regression-test/data/{load_p0/stream_load/load_json_null_to_nullable.out
=> cloud_p0/read_cluster_cache/warmup/test_warmup_delay_sc_query_tolerance.out}
(53%)
create mode 100644
regression-test/data/cloud_p0/read_cluster_cache/warmup/test_warmup_delay_timeout_compaction_query_tolerance.out
copy regression-test/data/{load_p0/stream_load/load_json_null_to_nullable.out
=> cloud_p0/read_cluster_cache/warmup/test_warmup_download_fail.out} (61%)
create mode 100644
regression-test/data/doc/sql-manual/sql-functions/doc_date_functions_test.out
create mode 100644
regression-test/data/external_table_p0/paimon/test_paimon_gcs.out
delete mode 100644
regression-test/data/inverted_index_p0/test_inverted_index_storage_format_upgrade.out
create mode 100644
regression-test/data/load_p0/broker_load/test_broker_load_with_negtive.out
copy regression-test/data/load_p0/{stream_load/load_json_null_to_nullable.out
=> broker_load/test_s3_load_with_set.out} (55%)
create mode 100644
regression-test/data/load_p0/insert/test_insert_strict_mode_and_filter_ratio.out
copy docker/thirdparties/docker-compose/kafka/scripts/basic_data.csv =>
regression-test/data/load_p0/load_ddl/full_columns_data.csv (100%)
create mode 100644
regression-test/data/load_p0/load_ddl/test_load_ddl_hidden_column.csv
create mode 100644
regression-test/data/load_p0/load_ddl/test_load_ddl_hidden_column_with_func.csv
create mode 100644
regression-test/data/load_p0/load_ddl/test_load_ddl_unavaliable_column.csv
create mode 100644
regression-test/data/load_p0/mysql_load/test_decimal_overflow.csv
create mode 100644
regression-test/data/load_p0/mysql_load/test_mysql_load_strict_mode_and_filter_ratio.out
create mode 100644
regression-test/data/load_p0/mysql_load/test_no_partition.csv
create mode 100644 regression-test/data/load_p0/mysql_load/test_not_number.csv
create mode 100644 regression-test/data/load_p0/mysql_load/test_null_number.csv
create mode 100644
regression-test/data/load_p0/routine_load/test_routine_load_strict_mode_and_filter_ratio.out
create mode 100644
regression-test/data/load_p0/stream_load/chinese_col_complex.csv
create mode 100644 regression-test/data/load_p0/stream_load/test_bitmap.csv
create mode 100644
regression-test/data/load_p0/stream_load/test_decimal_overflow.csv
create mode 100644
regression-test/data/load_p0/stream_load/test_no_partition.csv
create mode 100644 regression-test/data/load_p0/stream_load/test_not_number.csv
create mode 100644
regression-test/data/load_p0/stream_load/test_null_number.csv
copy
regression-test/data/{query_p0/sql_functions/ip_functions/test_is_ip_string_functions.out
=> load_p0/stream_load/test_stream_load_bitmap.out} (63%)
create mode 100644
regression-test/data/load_p0/stream_load/test_stream_load_strict_mode_and_filter_ratio.out
copy regression-test/data/load_p0/stream_load/{load_json_null_to_nullable.out
=> test_stream_load_with_set.out} (70%)
create mode 100644 regression-test/data/load_p0/tvf/test_tvf_error_data.out
create mode 100644
regression-test/data/load_p0/tvf/test_tvf_strict_mode_and_filter_ratio.out
create mode 100644
regression-test/data/nereids_p0/stats/col_stats/hot_value_str_to_date.out
create mode 100644
regression-test/data/nereids_rules_p0/expression/test_simplify_comparison_predicate_int_vs_double.out
create mode 100644
regression-test/data/query_p0/schema_table/test_sql_block_rule_status.out
create mode 100644
regression-test/data/query_p0/sql_functions/json_functions/test_json_exists_path.out
copy regression-test/data/{load_p0/stream_load/load_json_null_to_nullable.out
=> schema_change_p0/test_schema_change_with_empty_rowset.out} (61%)
create mode 100644
regression-test/framework/src/main/groovy/org/apache/doris/regression/util/GlobalLock.groovy
create mode 100644
regression-test/framework/src/main/groovy/org/apache/doris/regression/util/RemoteFileOperator.groovy
create mode 100644
regression-test/suites/ann_index_p0/cast_string_as_array.groovy
create mode 100644
regression-test/suites/ann_index_p0/scalar_quantization.groovy
rename
fe/fe-core/src/main/java/org/apache/doris/analysis/SetUserDefinedVar.java =>
regression-test/suites/cast_p0/cast_between_datetime.groovy (57%)
create mode 100644
regression-test/suites/cloud_p0/read_cluster_cache/no_warmup/test_enable_prefer_cached_rowset.groovy
create mode 100644
regression-test/suites/cloud_p0/read_cluster_cache/no_warmup/test_query_freshness_tolerance.groovy
create mode 100644
regression-test/suites/cloud_p0/read_cluster_cache/warmup/test_warmup_delay_compaction_query_tolerance.groovy
create mode 100644
regression-test/suites/cloud_p0/read_cluster_cache/warmup/test_warmup_delay_idx_query_tolerance.groovy
create mode 100644
regression-test/suites/cloud_p0/read_cluster_cache/warmup/test_warmup_delay_sc_query_tolerance.groovy
create mode 100644
regression-test/suites/cloud_p0/read_cluster_cache/warmup/test_warmup_delay_timeout_compaction_query_tolerance.groovy
copy
regression-test/suites/cloud_p0/{cache/multi_cluster/warm_up/cluster/test_warm_up_cluster_event_schema_change.groovy
=> read_cluster_cache/warmup/test_warmup_download_fail.groovy} (51%)
create mode 100644
regression-test/suites/cloud_p0/snapshot/test_snapshot_command.groovy
create mode 100644
regression-test/suites/cloud_p0/test_read_cluster_var_property.groovy
create mode 100644
regression-test/suites/doc/sql-manual/sql-functions/doc_date_functions_test.groovy
create mode 100644
regression-test/suites/external_table_p0/paimon/test_paimon_gcs.groovy
rename regression-test/suites/external_table_p2/{iceberg =>
refactor_catalog_param}/iceberg_rest_s3_storage_vended_test.groovy (100%)
rename
regression-test/suites/external_table_p2/{iceberg/iceberg_rest_s3_storage_test.groovy
=> refactor_catalog_param/iceberg_rest_storage_test.groovy} (77%)
create mode 100644
regression-test/suites/insert_p0/transaction/test_txn_limit.groovy
delete mode 100644
regression-test/suites/inverted_index_p0/test_inverted_index_storage_format_upgrade.groovy
create mode 100644
regression-test/suites/load/insert/test_too_many_versions_detection.groovy
create mode 100644
regression-test/suites/load_p0/broker_load/test_broker_load_with_negtive.groovy
create mode 100644
regression-test/suites/load_p0/broker_load/test_s3_load_with_set.groovy
create mode 100644
regression-test/suites/load_p0/insert/test_insert_strict_mode_and_filter_ratio.groovy
copy
docker/thirdparties/docker-compose/kafka/scripts/basic_data_json_by_line.json
=>
regression-test/suites/load_p0/load_ddl/data/load_ddl_basic_data_json_by_line.json
(100%)
create mode 100644
regression-test/suites/load_p0/load_ddl/ddl/agg_tbl_basic_create.sql
create mode 100644
regression-test/suites/load_p0/load_ddl/ddl/agg_tbl_basic_drop.sql
create mode 100644
regression-test/suites/load_p0/load_ddl/ddl/test_load_ddl_hidden_column_create.sql
create mode 100644
regression-test/suites/load_p0/load_ddl/ddl/test_load_ddl_hidden_column_drop.sql
create mode 100644
regression-test/suites/load_p0/load_ddl/ddl/test_load_ddl_unavaliable_column_create.sql
create mode 100644
regression-test/suites/load_p0/load_ddl/ddl/test_load_ddl_unavaliable_column_drop.sql
create mode 100644 regression-test/suites/load_p0/load_ddl/test_load_ddl.groovy
create mode 100644
regression-test/suites/load_p0/load_ddl/test_routine_load_advanced_mapping.groovy
create mode 100644
regression-test/suites/load_p0/load_ddl/test_stream_load_advanced_mapping.groovy
create mode 100644
regression-test/suites/load_p0/mysql_load/test_mysql_load_strict_mode_and_filter_ratio.groovy
create mode 100644
regression-test/suites/load_p0/routine_load/data/test_decimal_overflow.csv
create mode 100644
regression-test/suites/load_p0/routine_load/data/test_no_partition.csv
create mode 100644
regression-test/suites/load_p0/routine_load/data/test_not_number.csv
create mode 100644
regression-test/suites/load_p0/routine_load/data/test_strict_mode_and_filter_ratio.csv
create mode 100644
regression-test/suites/load_p0/routine_load/test_routine_load_strict_mode_and_filter_ratio.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_chinese_col_load.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_s3_bytes_written_metrics.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_stream_load_bitmap.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_stream_load_strict_mode_and_filter_ratio.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_stream_load_with_set.groovy
create mode 100644
regression-test/suites/load_p0/tvf/test_tvf_error_column.groovy
create mode 100644
regression-test/suites/load_p0/tvf/test_tvf_error_data.groovy
create mode 100644
regression-test/suites/load_p0/tvf/test_tvf_strict_mode_and_filter_ratio.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_hive_empty_partition_mtmv.groovy
create mode 100644
regression-test/suites/mv_p0/agg_table_mv/agg_table_mv.groovy
delete mode 100644
regression-test/suites/nereids_p0/datatype/test_compatible.groovy
create mode 100644
regression-test/suites/nereids_p0/stats/col_stats/hot_value_str_to_date.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/expression/test_simplify_comparison_predicate_int_vs_double.groovy
rename
regression-test/suites/nereids_rules_p0/partition_prune/{test_date_function_prune_mono.groovy
=> test_date_prune_mono.groovy} (99%)
create mode 100644
regression-test/suites/query_p0/schema_table/test_sql_block_rule_status.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/conditional_functions/data.txt
create mode 100644
regression-test/suites/query_p0/sql_functions/json_functions/test_json_exists_path.groovy
delete mode 100644
regression-test/suites/query_p0/test_select_with_predicate_like.groovy
copy
regression-test/suites/schema_change_p0/{test_schema_change_mow_with_empty_rowset.groovy
=> test_schema_change_with_empty_rowset.groovy} (80%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
