This is an automated email from the ASF dual-hosted git repository.
BiteTheDDDDt pushed a change to branch dev_runtime_partition_prune
in repository https://gitbox.apache.org/repos/asf/doris.git
discard 586640a94f4 [fix](be) Tighten runtime filter partition pruning checks
discard fb1122e0a26 update
discard 32e14d62202 update
discard 2ede6c8cafb [fix](be) Address RF pruning review comments
discard dd4e93ae028 [fix](regression) Stabilize RF pruning type matrix
discard 9af6867af36 update
discard 36cd8599c1b update
discard 3d38dc5ab81 [fix](regression) Stabilize RF partition pruning suite
discard d93998b1235 [fix](be) Fix RF partition pruner BE UT build
discard f779760a4db [fix](be) Fix RF partition pruner build after rebase
discard 0f1de960017 [fix](fe) Reject unsafe RF partition pruning targets
discard ee5e44758db [fix](fe) Reject non-first range RF pruning targets
discard 4eebb2424b0 [improvement](be) Validate RF partition pruning metadata
discard b9f95bbd743 [improvement](be) Use per-partition RF monotonicity
discard 0ce8b53d528 [improvement](be) Unify RF partition pruning target
handling
discard aea4c454412 [fix](be) Preserve open RF pruning boundaries
discard 58f39952c6e [refactor](be) Simplify runtime filter partition pruner
state
discard 3d7e57a398c [test](runtime-filter) Add partition pruner type coverage
discard 64899496e96 update
discard a64ff68f887 update
discard 475ba092677 fix
discard 0dc5621cd88 update
discard 7ebc576bf03 update
discard c33d49a9a55 [fix](fe) Centralize RF partition pruning classification
discard 085682035ee [chore](runtime-filter) Remove unused partition tablet
mapping
discard 628f8bc1052 [fix](runtime-filter) Fix projection cache lifetime
discard e7141280927 [feature](runtime-filter) Add runtime filter partition
pruning
add 5966c2edfc4 [Enhancement](skill) Add some details agents instructions
(#63627)
add dc6d28a3b6b [improvement](be) Eliminate redundant MultiCast block
copies (#63580)
add eb46d1ebf14 [fix](regression) Stabilize variant hirachinal array
output (#63610)
add 647d5a77881 [bug](jdbc) fix sqlserver couldn't get schema with higher
version driver jar (#63626)
add ff1012da3e9 [fix](be) Fix time-sharing executor queued task count
(#63568)
add b1c01331a6f [feature](function) Add ST_NumGeometries, ST_NumPoints,
ST_Geometries functions (#63049)
add b95038ed42d [fix](be) Preserve shuffle for serial merge aggregation
(#63529)
add aec06f991d9 [fix](metric) Preserve labels for histogram metrics to fix
wrong metric name for prometheus (#63485)
add 1d72e0f22c3 [improvement](executor) use real elapsed time to compute
workload group metrics refresh interval (#63537)
add 0ebf7b4d58c [opt](memory) optimize row-store memtable flush memory in
the row-store scenario (#63342)
add 305e88540f7 [fix](parser) isNull should under primaryExpression
(#63619)
add 825f5ce49fe [test](streaming-job) refine cdc data-type and boundary
regression cases for mysql/pg (#63404)
add 99cb71a59b8 [opt](memory) truncate segment key bounds before storing
segment stats (#63469)
add d0536c04c51 [refine](column) use strong-typed ColumnUInt8 for null_map
in ColumnNullable (#63491)
add 090b4768f82 [regression-test](streaming-job) add cdc cases
(composite/concurrent-dml/id-gap/decimal/datetime pk) and fix split-bound
java.time deserialize (#63471)
add 35433413a56 [fix](streaming-job) misc fixes for
typo/log/validation/visibility (#63480)
add 76fd6ecf20d [Fix](CI) Avoid AI Review opinion line breaks (#63672)
add d626a5486a0 [fix](be) Include HDFS connection in file handle cache key
(#63516)
add 65661ffff67 [opt](group-commit) Skip createLocation in group commit
stream load sink (#63561)
add db27399d28a [opt](fe) Bound not-null inference cost (#63318)
add 41581e5700c [fix](streaming-job) drop neighbour-table rows leaked by
JDBC LIKE wildcards in JdbcPostgreSQLClient (#63402)
add 2b08baabe5c [test](docker) Verify DML and 3-replica create table when
one BE is down (#63401)
add f9fea7d33c6 [fix](planner) align legacy literal compareLiteral with
Nereids ComparableLiteral semantics (#63481)
add 2a94cd8e085 [fix](be) Limit backward clock warning logs (#63620)
add 36429ee4415 [fix](env) fix beut build (#63691)
add 9c87a674409 [fix](mv) Avoid unioning query-unused MV partitions
(#63081)
add 85181f5a0e1 [fix](fe) Preserve operative slots when deep copying
logical relations (#63315)
add d1eef1ed4d7 [fix](case)fix iceberg unstable case. (#63542)
add 78287c0245b [fix](test) fix regression test agg_strategy shape change
(#63606)
add 1aa32e488d0 [fix](docker) support DNS readiness for Doris pods (#63715)
add fea3d44609b [fix](variant) clamp variant_sparse_hash_shard_count to
>=1 in SHOW CREATE output (#63661)
add 7fa4d2ed99f [regression-test](streaming-job) add cdc operational cases
for offset modes and pg slot lifecycle (#63514)
add cba3cac5a2f [Fix](Query Stats) Add QueryStatsRecorder for column-level
query and filter - Part1 (#63067)
add f7af0aa9708 [fix](compile) guard MD5 AVX2-only symbols under __AVX2__
(#63723)
add 9fe0c1ce178 [refactor](be) Remove scanner eos flag (#63578)
add 3884c1aba86 [fix](function) fix tokenize function incorrect result
when first argument is const (#62699)
add ff0fbf56dba [fix](statistics) full analyze not collect hot value by
default (#63625)
add 732aad49040 [fix](regression-test) stabilize 2 muted external_table_p0
tests (#63646)
add f80619380a1 [fix](variant) Bind Variant search to nested indexes
(#63660)
add 4d3097ec980 [fix](be) Handle legacy DecimalV2 segments with missing
precision/frac (#63569)
add 5fae02f85b3 [fix](regression) Make Iceberg rewrite where init script
idempotent (#63673)
add 05690fce06f [fix](compile) disambiguate Aws::Utils::DateTime ctor in
kinesis_conf (#63727)
add c24d454f15c [fix](search) reject Lucene-syntax SEARCH on columns
without inverted index (#63637)
add 2e72603618c [fix](variant) preserve TIMESTAMPTZ values in sparse path
(#63522)
add 5e9126cf5b2 [fix](fe) Normalize default HDFS paths in LocationPath
(#63476)
add 1284b254c0a [fix](test) delete unstable case in agg_strategy (#63726)
add 67260ed932a [feat](job) add per-job routine load metrics (#63576)
add 48d62f4161d [fix](regression) Wait row count before hot value analyze
(#63758)
add 997685763c4 [improvement](cloud) Enable packed file and empty rowset
optimization by default (#63475)
add 24cb2f77cb2 [fix](cloud) Skip wait for async rowset warmup (#62764)
add df200d8cbe1 [fix](hive table) Fill Hive meta cache when loading row
count for queries (#63470)
add 84e47b65088 [fix](function) Improve numerical robustness of
cosine_distance / cosine_similarity (#62840)
add d1060850bed [fix](show variables) Fix changed variable output in show
variables (#63734)
add a04dac6b6fc [fix](match) Allow MATCH on aliased variant subcolumns
(#63772)
add a0e0ee55cf6 [fix](streaming-job) fix postgres historical-date
timestamp handling in cdc-client (#63618)
add 7c4dfe9f289 [improve](streaming-job) support user-specified mysql
server_id with per-reader assignment (#63490)
add a95974c6dde [BUG](exec) fix coalesce function output null (#63092)
add a183718e000 [fix](coordinator) fix computeDestIdToInstanceId picking
wrong ExchangeNode for multi-input fragments (#63615)
add 345f6b978d0 [fix](cloud) CloudUpgradeMgr inspect and abort failed
conflict txns while waiting (#60830)
add d232caa5330 [fix](be) Preserve agg hash shuffle after non-hash
exchange (#63766)
add ce0784d7e32 [fix](test) Cast variant subcolumn as json in
variant_hirachinal for stable output (#63828)
add 0bd933ceecf [fix](be) Keep prefetch reader alive for async tasks
(#63796)
add c27fef6ac08 [fix](file cache) guard null IOContext in cached remote
reader (#63842)
add 87316004891 [fix](be) Fix timestamptz group_array state serde (#63827)
add 99691f6895d [refine](function) use typed ANN query vector (#63834)
add b653831c9fc [fix](function) deduplicate map keys after string-to-map
cast (#63713)
add 4f1dcdf3395 [refactor](BE) split EncodingInfo defaults into 4 explicit
maps (#63622)
add 9688e57f280 [fix](cloud) normalize SHOW PARTITIONS display for storage
and replica (#60871)
add 2ddf97a1a38 [fix](ann-index) Fix ANN range search state leakage and
incorrect slot index tracking. (#63666)
add 2570dd88f62 [fix](fe) Remove decimal literal debug logs (#63841)
add 113fd2da342 Add levenshtein and hamming_distance functions (#60412)
add 1e8e91dbee1 [fix](recycler) Reduce recycle_job_lease_expired_ms for
SnapshotDataMigrator (#63388)
add aa68e4bd9e7 [Enhancement](udf) Reject bitmap, hll, and quantile_state
in udf create (#63849)
add 6e27f117471 [improve](streaming-job) avoid potential OOM when reading
large snapshot splits (#63833)
add 7fc8e276284 [feat](sql-parser) Split SQL grammar into standalone
fe-sql-parser (#63823)
add 148429f699e [fix](test) Wait for target rowset count in
test_time_series_compaction_policy (#63890)
add a7ad76ae570 [fix](be) Preserve null probe rows in mark anti join
(#63767)
add 477cb0c6bba [improvement](be) Add release-enabled Doris check macros
(#63730)
add 3c9c40fa5fd [fix](fe) Fix broken pipe risk on stream load redirect
with unconsumed request body (#63332)
add d7c033f7f34 [Fix](variance) Fix sample variance/stddev NaN res for
single value (#63605)
add c59abe09e60 [Fix](FoldConst) Preserve NaN in numeric constant folding
(#63870)
add 1b44c051649 Add datasketches HLL sketch aggregate functions (#63143)
add 6e5198b7cea [test](regression) Add debug point ANN index-only scan
test (#63859)
add 487f7833346 [Enhancement](udf) Do not check file when inline code
exists (#63906)
add e0729979c71 [refactor](be) remove CHAR padding on read (#63291)
add 4a0c58bcbcd [fix](cloud) Drain txn lazy committer workers before
destruction (#63876)
add a1f66eb96f7 [fix](fe) Keep cached file systems alive while in use
(#63677)
add 17617be150e [fix] (cloud) Fix local/remote tablet size semantics in
schema views (#60887)
add 7a79dd88a5f [fix](iceberg)fix iceberg v3 row lineage count distinct
error result (#63826)
add d1e30df5565 [fix](cloud) Align colocate proc output and tablet health
in cloud mode (#60944)
add ba86267294c [fix](regression) fix unstable
test_audit_log_internal_query_failure due to other cases modify global vars
(#63030)
add eeef49eafdc [enhance](job) add zero-row hint for Kafka read_committed
load (#63664)
add 5b5b2ae1330 [feat](cloud) Add system rate limit for meta-service
(#61516)
add 8db9a80d120 [fix](point-query) Refresh stale prepared short-circuit
plans (#63920)
add 905c80433b1 [fix](expr) fix mixed const probe constant handling
regressions (#63810)
add 18677371380 [fix](fe) Fix assert row join pushdown alias handling
(#63892)
add d898a1d90d6 [feature](fe) Push down limit into CTE producer (#63675)
add 3f5582b3ace [fix](fe) Skip dropped columns in follower stats sync
(#63882)
add a9a87f86796 [chore](cloud) Support dynamic recycler instance filter
config (#63822)
add 2ad56a85edb [refine](column) strong type array and map offsets (#63678)
add 04624351573 [fix](be ut) Skip custom memcpy on ARM+ASAN to fix
segfault at process startup (#63656)
add c2432387467 [Enhancement](udf) support volatility for udaf && udtf
(#63611)
add d7f9fa57f2a [refactor](be)simplify interface in schema and rowcursor
(#63925)
add d8517272213 [fix](variant) Remove deprecated flatten nested setting
from P1 regression (#63840)
add 5db57341993 [Enhancement](mv): Improve MV predicate compensation and
keep original min-max predicates non-inferred (#61345)
add f68eda67aad [Feature](skill) Introduce Doris profile reader skill
(#63948)
add 679081e39db [feature](runtime filter) Add decoupled runtime filter
support (#62737)
add 0b3d70c1407 [fix](transaction) select txn insert backend from current
cluster (#63634)
add c7449c6434f [fix](filecache) avoid crash when late holder cleanup sees
removed cache cell (#62437)
add c0841744d1d [fix](filecache) add async lru update machanism and fix
partial hit in cache reader (#61083)
add 138ab5cb1f4 [fix](filecache) fix clear_file_cache right after reboot
causing file cache size percent overflow (#63410)
add 627fba17c6f [chore](doc) Improve README formatting for clarity (#63905)
add cada7b9f0fc Revert "[Feature](skill) Introduce Doris profile reader
skill" (#63959)
add f0d256b48c5 [chore](build) Add doris-skills submodule (#63961)
add a94e99a5135 [feature](runtime-filter) Add runtime filter partition
pruning
add 3cba7548955 [fix](runtime-filter) Fix projection cache lifetime
add 7c8487a9b89 [chore](runtime-filter) Remove unused partition tablet
mapping
add 66d317cddd5 [fix](fe) Centralize RF partition pruning classification
add 713f3111f66 update
add 0e138551379 update
add 7c9c931a023 fix
add a021c09d08e update
add 178580ee897 update
add 68d616e7aa0 [test](runtime-filter) Add partition pruner type coverage
add 635bb2b82ae [refactor](be) Simplify runtime filter partition pruner
state
add 37a4e81bac9 [fix](be) Preserve open RF pruning boundaries
add e686adcb6cf [improvement](be) Unify RF partition pruning target
handling
add 156e0c0c7eb [improvement](be) Use per-partition RF monotonicity
add b72f9b1656f [improvement](be) Validate RF partition pruning metadata
add 0ede8710ebd [fix](fe) Reject non-first range RF pruning targets
add fc948f9585d [fix](fe) Reject unsafe RF partition pruning targets
add b90d1b0d641 [fix](be) Fix RF partition pruner build after rebase
add 421e66b61ef [fix](be) Fix RF partition pruner BE UT build
add 0bb79d213ca [fix](regression) Stabilize RF partition pruning suite
add 3722e93dc69 update
add 1e0cf1d9d31 update
add 7e50f275f03 [fix](regression) Stabilize RF pruning type matrix
add 1721ef38427 [fix](be) Address RF pruning review comments
add 412fed30c92 update
add 734c268df5b update
add b82194ce0fb [fix](be) Tighten runtime filter partition pruning checks
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 (586640a94f4)
\
N -- N -- N refs/heads/dev_runtime_partition_prune (b82194ce0fb)
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.
No new revisions were added by this update.
Summary of changes:
.github/workflows/opencode-review-runner.yml | 1 +
.gitmodules | 7 +
AGENTS.md | 2 +-
README.md | 10 +-
be/src/cloud/cloud_meta_mgr.cpp | 12 +
be/src/cloud/cloud_warm_up_manager.cpp | 32 +-
be/src/cloud/config.cpp | 4 +-
be/src/cloud/pb_convert.cpp | 12 +
.../inverted_index_stats.h => common/check.cpp} | 17 +-
be/src/common/check.h | 154 +++
be/src/common/config.cpp | 3 +-
be/src/common/config.h | 1 +
be/src/common/status.h | 9 +-
be/src/core/block/block.cpp | 15 -
be/src/core/block/block.h | 3 -
be/src/core/column/column.h | 4 -
be/src/core/column/column_array.cpp | 39 +-
be/src/core/column/column_array.h | 32 +-
be/src/core/column/column_const.h | 5 +-
be/src/core/column/column_dictionary.h | 27 +-
be/src/core/column/column_map.cpp | 49 +-
be/src/core/column/column_map.h | 48 +-
be/src/core/column/column_nullable.cpp | 68 +-
be/src/core/column/column_nullable.h | 35 +-
be/src/core/column/column_string.cpp | 23 -
be/src/core/column/column_string.h | 2 -
be/src/core/column/column_struct.cpp | 6 -
be/src/core/column/column_struct.h | 4 +-
be/src/core/column/column_variant.cpp | 2 +-
be/src/core/column/column_variant.h | 6 +-
be/src/core/column/predicate_column.h | 6 +-
be/src/core/cow.h | 5 +-
be/src/core/data_type/data_type_array.cpp | 6 +-
be/src/core/data_type/data_type_factory.cpp | 19 +-
be/src/core/data_type/data_type_map.cpp | 5 +-
.../data_type_serde/data_type_string_serde.cpp | 23 +-
.../data_type_timestamptz_serde.cpp | 17 +
.../data_type_serde/data_type_timestamptz_serde.h | 4 +
be/src/exec/common/hash_table/join_hash_table.h | 5 +-
.../exec/exchange/local_exchange_source_operator.h | 5 +
be/src/exec/operator/aggregation_sink_operator.cpp | 5 +-
be/src/exec/operator/aggregation_sink_operator.h | 4 +-
.../distinct_streaming_aggregation_operator.h | 4 +-
be/src/exec/operator/hashjoin_build_sink.cpp | 4 +-
be/src/exec/operator/multi_cast_data_streamer.cpp | 12 +-
be/src/exec/operator/multi_cast_data_streamer.h | 5 +-
be/src/exec/operator/operator.cpp | 17 +
be/src/exec/operator/operator.h | 3 +
.../exec/operator/streaming_aggregation_operator.h | 7 +-
be/src/exec/operator/table_function_operator.cpp | 9 +-
be/src/exec/pipeline/pipeline.cpp | 10 +-
be/src/exec/rowid_fetcher.cpp | 46 -
be/src/exec/runtime_filter/runtime_filter.cpp | 3 +
.../exec/runtime_filter/runtime_filter_consumer.h | 19 +-
.../runtime_filter_producer_helper.cpp | 61 +-
.../runtime_filter_producer_helper.h | 16 +-
.../runtime_filter_producer_helper_cross.h | 5 +-
be/src/exec/scan/scanner.cpp | 53 +-
be/src/exec/scan/scanner.h | 1 -
.../time_sharing/time_sharing_task_executor.cpp | 44 +-
.../time_sharing/time_sharing_task_executor.h | 9 +
.../exprs/aggregate/aggregate_function_collect.h | 7 +
...gregate_function_datasketches_hll_union_agg.cpp | 44 +
...aggregate_function_datasketches_hll_union_agg.h | 243 +++++
.../aggregate_function_simple_factory.cpp | 3 +
be/src/exprs/aggregate/aggregate_function_stddev.h | 28 +-
be/src/exprs/bloom_filter_func_adaptor.h | 14 +-
be/src/exprs/bloom_filter_func_impl.h | 15 +-
.../function/array/function_array_distance.cpp | 38 +-
.../exprs/function/array/function_array_exists.cpp | 3 +-
.../exprs/function/array/function_array_filter.cpp | 8 +-
.../function/array/function_array_flatten.cpp | 4 +-
be/src/exprs/function/cast/cast_to_map.h | 48 +-
.../exprs/function/function_always_not_nullable.h | 3 +-
.../exprs/function/function_hamming_distance.cpp | 320 ++++++
be/src/exprs/function/function_hll.cpp | 3 +-
be/src/exprs/function/function_jsonb.cpp | 17 +-
be/src/exprs/function/function_levenshtein.cpp | 263 +++++
be/src/exprs/function/function_quantile_state.cpp | 5 +-
be/src/exprs/function/function_regexp.cpp | 20 +-
be/src/exprs/function/function_search.cpp | 720 ++++---------
be/src/exprs/function/function_search.h | 99 +-
be/src/exprs/function/function_tokenize.cpp | 18 +-
be/src/exprs/function/function_tokenize.h | 2 +-
be/src/exprs/function/geo/functions_geo.cpp | 165 +++
be/src/exprs/function/geo/geo_types.cpp | 15 +
be/src/exprs/function/geo/geo_types.h | 15 +
be/src/exprs/function/if.cpp | 24 +-
be/src/exprs/function/simple_function_factory.h | 4 +
be/src/exprs/function/uniform.cpp | 2 +
.../function/variant_inverted_index_search.cpp | 720 +++++++++++++
.../exprs/function/variant_inverted_index_search.h | 218 ++++
.../lambda_function/varray_filter_function.cpp | 8 +-
.../exprs/lambda_function/varray_map_function.cpp | 8 +-
.../exprs/lambda_function/varray_sort_function.cpp | 4 +-
.../exprs/table_function/python_udtf_function.cpp | 7 +-
be/src/exprs/table_function/udf_table_function.cpp | 7 +-
be/src/exprs/table_function/vexplode.cpp | 7 +-
be/src/exprs/table_function/vexplode_bitmap.cpp | 8 +-
.../exprs/table_function/vexplode_json_object.cpp | 7 +-
be/src/exprs/table_function/vexplode_map.cpp | 7 +-
be/src/exprs/table_function/vexplode_numbers.cpp | 4 +-
be/src/exprs/table_function/vexplode_numbers.h | 13 +-
be/src/exprs/table_function/vexplode_v2.cpp | 12 +-
be/src/exprs/table_function/vjson_each.cpp | 6 +-
be/src/exprs/vcase_expr.h | 5 +-
be/src/exprs/vcompound_pred.h | 5 +-
be/src/exprs/vcondition_expr.cpp | 28 +-
be/src/exprs/vectorized_fn_call.cpp | 18 +-
be/src/exprs/vectorized_fn_call.h | 2 +-
be/src/exprs/vexpr.cpp | 12 +-
be/src/exprs/vexpr.h | 22 +-
be/src/exprs/vexpr_context.cpp | 37 +-
be/src/exprs/vexpr_context.h | 2 +-
be/src/exprs/virtual_slot_ref.cpp | 6 +-
be/src/exprs/virtual_slot_ref.h | 2 +-
be/src/exprs/vsearch.cpp | 56 +
be/src/format/native/native_reader.cpp | 11 +-
be/src/format/parquet/vparquet_group_reader.cpp | 30 +-
be/src/format/parquet/vparquet_group_reader.h | 4 +-
be/src/glibc-compatibility/CMakeLists.txt | 11 +-
be/src/io/cache/block_file_cache.cpp | 65 +-
be/src/io/cache/block_file_cache.h | 5 +-
be/src/io/cache/cached_remote_file_reader.cpp | 12 +-
be/src/io/cache/file_block.cpp | 3 +-
be/src/io/fs/buffered_reader.cpp | 4 +-
be/src/io/fs/buffered_reader.h | 8 +-
be/src/io/fs/file_handle_cache.cpp | 20 +-
be/src/io/fs/file_handle_cache.h | 21 +-
be/src/load/routine_load/kinesis_conf.cpp | 3 +-
.../workload_group/workload_group_metrics.cpp | 9 +-
.../workload_group/workload_group_metrics.h | 1 +
be/src/service/internal_service.cpp | 7 +
be/src/service/point_query_executor.cpp | 12 +-
be/src/storage/delete/delete_handler.cpp | 20 +-
.../storage/index/ann/ann_range_search_runtime.cpp | 3 +-
.../storage/index/ann/ann_range_search_runtime.h | 2 +-
be/src/storage/index/ann/ann_topn_runtime.cpp | 19 +-
be/src/storage/index/ann/ann_topn_runtime.h | 5 +-
be/src/storage/index/indexed_column_reader.cpp | 2 +-
be/src/storage/index/indexed_column_writer.cpp | 13 +-
.../index/inverted/inverted_index_profile.h | 9 +
.../storage/index/inverted/inverted_index_stats.h | 14 +
.../query_v2/bit_set_query/bit_set_query.h | 8 +-
.../query_v2/bit_set_query/bit_set_weight.h | 6 +-
be/src/storage/index/primary_key_index.cpp | 2 +-
be/src/storage/index/zone_map/zone_map_index.cpp | 3 +-
be/src/storage/predicate/comparison_predicate.h | 7 +-
be/src/storage/predicate/in_list_predicate.h | 24 +-
be/src/storage/predicate/like_column_predicate.h | 2 +-
.../predicate/predicate_creator_comparison.cpp | 18 +-
.../predicate/predicate_creator_in_list_in.cpp | 35 +-
.../predicate/predicate_creator_in_list_not_in.cpp | 33 +-
be/src/storage/row_cursor.cpp | 45 +-
be/src/storage/row_cursor.h | 14 +-
be/src/storage/rowset/beta_rowset_writer.cpp | 42 +-
be/src/storage/schema.cpp | 2 -
be/src/storage/schema.h | 57 -
be/src/storage/segment/binary_dict_page.cpp | 19 +-
be/src/storage/segment/binary_dict_page.h | 7 +-
.../storage/segment/binary_dict_page_pre_decoder.h | 30 +-
.../binary_plain_page_char_strip_pre_decoder.h | 98 ++
.../segment/binary_plain_page_v2_pre_decoder.h | 248 +++--
be/src/storage/segment/binary_prefix_page.h | 2 +-
be/src/storage/segment/column_reader.cpp | 92 +-
be/src/storage/segment/column_reader.h | 2 +-
be/src/storage/segment/column_writer.cpp | 41 +-
be/src/storage/segment/column_writer.h | 9 +-
be/src/storage/segment/encoding_info.cpp | 464 +++++----
be/src/storage/segment/encoding_info.h | 129 ++-
be/src/storage/segment/options.h | 11 +-
be/src/storage/segment/page_io.cpp | 16 +-
be/src/storage/segment/page_io.h | 5 -
be/src/storage/segment/segment.cpp | 49 +-
be/src/storage/segment/segment_iterator.cpp | 99 +-
be/src/storage/segment/segment_iterator.h | 8 +-
be/src/storage/segment/segment_writer.cpp | 26 +-
be/src/storage/segment/segment_writer.h | 2 +-
.../segment/variant/variant_column_reader.cpp | 51 +-
.../segment/variant/variant_column_reader.h | 4 +-
.../segment/variant/variant_column_writer_impl.cpp | 24 +-
.../segment/variant/variant_column_writer_impl.h | 2 +-
be/src/storage/segment/vertical_segment_writer.cpp | 147 ++-
be/src/storage/segment/vertical_segment_writer.h | 7 +-
be/src/storage/tablet/tablet_meta.cpp | 18 +-
be/src/storage/tablet/tablet_reader.cpp | 10 +-
be/src/storage/tablet/tablet_schema.cpp | 43 +-
be/src/storage/tablet/tablet_schema.h | 36 +-
be/src/util/jsonb/serialize.cpp | 28 +-
be/src/util/jsonb/serialize.h | 8 +
be/src/util/md5.cpp | 13 +-
be/src/util/simd/vstring_function.h | 16 +
be/src/util/stopwatch.hpp | 7 +-
be/test/AGENTS.md | 5 +
be/test/cloud/cloud_warm_up_manager_test.cpp | 298 ++++++
be/test/common/check_test.cpp | 161 +++
be/test/core/block/block_test.cpp | 2 -
be/test/core/column/column_array_test.cpp | 13 +-
be/test/core/column/column_const_test.cpp | 13 +
be/test/core/column/column_map_test.cpp | 8 +-
be/test/core/column/column_string_test.cpp | 22 -
be/test/core/column/common_column_test.h | 37 -
be/test/core/data_type/data_type_decimal_test.cpp | 179 ++++
.../data_type_serde_timestamptz_test.cpp | 83 ++
be/test/data/vec/columns/TIMESTAMPTZ(3).csv | 16 +
be/test/exec/common/schema_util_rowset_test.cpp | 28 +-
.../time_sharing_task_executor_test.cpp | 78 +-
.../agg_operator_group_by_limit_opt_test.cpp | 8 +-
be/test/exec/operator/agg_operator_test.cpp | 65 +-
...istinct_streaming_aggregation_operator_test.cpp | 15 +
.../exec/operator/streaming_agg_operator_test.cpp | 14 +
.../exec/operator/table_function_operator_test.cpp | 3 +-
.../runtime_filter_producer_helper_test.cpp | 74 ++
be/test/exec/scan/scanner_late_arrival_rf_test.cpp | 52 +-
be/test/exec/scan/vgeneric_iterators_test.cpp | 21 +-
.../agg_datasketches_hll_union_agg_test.cpp | 1097 ++++++++++++++++++++
be/test/exprs/bloom_filter_func_test.cpp | 6 +-
.../function_array_cosine_similarity_test.cpp | 79 +-
be/test/exprs/function/function_math_test.cpp | 58 ++
.../function/function_quantile_state_test.cpp | 17 +
.../exprs/function/function_search_nested_test.cpp | 353 ++++++-
be/test/exprs/function/function_search_test.cpp | 463 +++++++++
be/test/exprs/function/function_string_test.cpp | 16 +
be/test/exprs/function/function_test_util.cpp | 6 +-
be/test/exprs/function/function_tokenize_test.cpp | 94 ++
be/test/exprs/function/geo/functions_geo_test.cpp | 455 ++++++++
be/test/exprs/vcondition_expr_test.cpp | 358 +++++++
be/test/io/cache/block_file_cache_test.cpp | 298 ++++++
be/test/io/cache/block_file_cache_test_common.h | 12 +-
.../io/cache/block_file_cache_test_lru_dump.cpp | 107 ++
.../cached_remote_file_reader_lock_wait_test.cpp | 444 ++++++++
.../io/cache/cached_remote_file_reader_test.cpp | 125 +++
be/test/io/cache/need_update_lru_blocks_test.cpp | 1 -
be/test/io/fs/buffered_reader_test.cpp | 85 +-
be/test/io/fs/file_handle_cache_test.cpp | 43 +
.../delta_writer/delta_writer_cluster_key_test.cpp | 15 +-
be/test/load/delta_writer/delta_writer_test.cpp | 19 +-
.../workload_group/workload_group_metrics_test.cpp | 152 +++
.../compaction/ordered_data_compaction_test.cpp | 10 +-
.../compaction/vertical_compaction_test.cpp | 10 +-
.../delete/delete_bitmap_calculator_test.cpp | 3 +-
.../storage/index/ann/ann_range_search_test.cpp | 216 +++-
.../storage/index/ann/ann_topn_descriptor_test.cpp | 3 +-
.../index/ann/extract_query_vector_test.cpp | 18 +-
.../index/inverted/query_v2/boolean_query_test.cpp | 22 +
be/test/storage/olap_type_test.cpp | 48 +
be/test/storage/row_cursor_test.cpp | 69 +-
be/test/storage/segment/binary_dict_page_test.cpp | 74 +-
.../storage/segment/binary_plain_page_v2_test.cpp | 145 ++-
.../storage/segment/column_meta_accessor_test.cpp | 17 +-
.../storage/segment/column_reader_cache_test.cpp | 39 +-
be/test/storage/segment/encoding_info_test.cpp | 476 +++++++--
.../segment/external_col_meta_util_test.cpp | 2 +-
be/test/storage/segment/segment_cache_test.cpp | 15 +-
.../storage/segment/segment_corruption_test.cpp | 6 +-
.../segment_iterator_apply_index_expr_test.cpp | 6 +-
.../segment/segment_iterator_limit_opt_test.cpp | 6 +-
.../segment_iterator_no_need_read_data_test.cpp | 6 +-
.../segment_writer_full_encode_keys_test.cpp | 100 --
.../segment/variant_column_writer_reader_test.cpp | 288 ++++-
be/test/storage/segment/zone_map_index_test.cpp | 48 +-
be/test/storage/tablet/tablet_schema_test.cpp | 66 ++
build.sh | 9 +
cloud/src/common/bvars.cpp | 1 +
cloud/src/common/bvars.h | 1 +
cloud/src/common/config.h | 18 +-
cloud/src/common/configbase.cpp | 22 +-
cloud/src/common/configbase.h | 3 +
cloud/src/common/http_helper.cpp | 61 ++
cloud/src/common/http_helper.h | 6 +
cloud/src/common/metric.cpp | 16 +
cloud/src/meta-service/CMakeLists.txt | 1 +
cloud/src/meta-service/meta_service_helper.h | 16 +
.../meta_service_rate_limit_helper.cpp | 843 +++++++++++++++
.../meta-service/meta_service_rate_limit_helper.h | 80 ++
cloud/src/meta-service/txn_lazy_committer.cpp | 57 +-
cloud/src/meta-service/txn_lazy_committer.h | 9 +-
cloud/src/recycler/recycler.cpp | 12 +-
cloud/src/recycler/recycler.h | 2 -
cloud/src/recycler/snapshot_chain_compactor.cpp | 5 +-
cloud/src/recycler/snapshot_data_migrator.cpp | 5 +-
cloud/test/CMakeLists.txt | 2 +-
cloud/test/meta_service_helper_test.cpp | 151 +++
cloud/test/recycler_test.cpp | 30 +
contrib/datasketches-cpp | 1 +
.../be/resource/be_disaggregated_entrypoint.sh | 65 +-
.../runtime/be/resource/be_disaggregated_probe.sh | 6 +
docker/runtime/be/resource/be_entrypoint.sh | 63 +-
.../fe/resource/fe_disaggregated_entrypoint.sh | 32 +
.../runtime/fe/resource/fe_disaggregated_probe.sh | 6 +
docker/runtime/fe/resource/fe_entrypoint.sh | 32 +
.../create_preinstalled_scripts/iceberg/run21.sql | 9 +-
.../create_preinstalled_scripts/iceberg/run27.sql | 9 +-
doris-skills | 1 +
fe/fe-catalog/pom.xml | 6 +
.../org/apache/doris/analysis/IPv4Literal.java | 31 +-
.../org/apache/doris/analysis/IPv6Literal.java | 45 +-
.../java/org/apache/doris/analysis/MapLiteral.java | 2 +-
.../org/apache/doris/analysis/StructLiteral.java | 2 +-
.../org/apache/doris/analysis/TimeV2Literal.java | 22 +-
.../org/apache/doris/analysis/ExprEqualsTest.java | 348 +++++++
.../analysis/LiteralExprCompareLiteralTest.java | 455 ++++++++
.../doris/analysis/LiteralExprEqualsTest.java | 366 +++++++
.../main/java/org/apache/doris/common/Config.java | 27 +-
.../apache/doris/job/cdc/DataSourceConfigKeys.java | 3 +
.../connector/jdbc/client/JdbcConnectorClient.java | 14 +-
.../jdbc/client/JdbcSQLServerConnectorClient.java | 7 +
.../client/JdbcSQLServerConnectorClientTest.java | 7 +
fe/fe-core/pom.xml | 5 +
.../apache/doris/analysis/AnalyzeProperties.java | 20 +
.../doris/catalog/BuiltinAggregateFunctions.java | 3 +
.../doris/catalog/BuiltinScalarFunctions.java | 10 +
.../apache/doris/catalog/ColocateTableIndex.java | 19 +-
.../apache/doris/catalog/DataSizeDisplayUtil.java | 78 ++
.../doris/catalog/FunctionToSqlConverter.java | 10 +-
.../java/org/apache/doris/catalog/OlapTable.java | 3 +
.../java/org/apache/doris/catalog/Replica.java | 21 +
.../apache/doris/cloud/catalog/CloudReplica.java | 53 +-
.../doris/cloud/catalog/CloudUpgradeMgr.java | 42 +
.../cloud/datasource/CloudInternalCatalog.java | 7 +-
.../proc/ColocationGroupBackendSeqsProcNode.java | 24 +-
.../doris/common/proc/ColocationGroupProcDir.java | 158 ++-
.../doris/common/proc/PartitionsProcDir.java | 17 +-
.../doris/common/proc/TabletHealthProcDir.java | 7 +-
.../apache/doris/common/proc/TabletsProcDir.java | 9 +-
.../org/apache/doris/common/util/LocationPath.java | 14 +-
.../doris/datasource/ExternalRowCountCache.java | 53 +-
.../org/apache/doris/datasource/ExternalTable.java | 13 +-
.../datasource/PluginDrivenExternalTable.java | 2 +-
.../doris/datasource/hive/HMSExternalTable.java | 28 +-
.../datasource/hive/HiveExternalMetaCache.java | 32 +-
.../doris/datasource/jdbc/client/JdbcClient.java | 14 +-
.../jdbc/client/JdbcPostgreSQLClient.java | 5 +
.../jdbc/client/JdbcSQLServerClient.java | 7 +
.../java/org/apache/doris/fs/FileSystemCache.java | 167 ++-
.../config/WebServerFactoryCustomizerConfig.java | 3 +
.../org/apache/doris/httpv2/rest/LoadAction.java | 152 ++-
.../doris/httpv2/rest/RestBaseController.java | 51 +-
.../httpv2/util/StreamLoadRedirectDrainUtil.java | 154 +++
.../streaming/DataSourceConfigValidator.java | 143 ++-
.../insert/streaming/StreamingInsertJob.java | 6 +-
.../insert/streaming/StreamingMultiTblTask.java | 5 +-
.../job/offset/jdbc/JdbcSourceOffsetProvider.java | 11 +-
.../offset/jdbc/JdbcTvfSourceOffsetProvider.java | 13 +-
.../routineload/kafka/KafkaRoutineLoadJob.java | 30 +
.../java/org/apache/doris/metric/CloudMetrics.java | 26 +-
.../apache/doris/metric/DorisMetricRegistry.java | 36 +
.../{MetricVisitor.java => HistogramMetric.java} | 47 +-
.../org/apache/doris/metric/JsonMetricVisitor.java | 18 +
.../java/org/apache/doris/metric/MetricRepo.java | 101 +-
.../org/apache/doris/metric/MetricVisitor.java | 4 +
.../doris/metric/PrometheusMetricVisitor.java | 24 +-
.../doris/metric/SimpleCoreMetricVisitor.java | 6 +
.../org/apache/doris/nereids/CascadesContext.java | 8 +
.../org/apache/doris/nereids/NereidsPlanner.java | 4 +
.../org/apache/doris/nereids/StatementContext.java | 22 +
.../doris/nereids/exceptions/CastException.java | 2 +-
.../glue/translator/RuntimeFilterTranslator.java | 23 +
.../doris/nereids/jobs/executor/Rewriter.java | 3 +
.../doris/nereids/parser/LogicalPlanBuilder.java | 44 +-
.../processor/post/RuntimeFilterContext.java | 29 +
.../processor/post/RuntimeFilterGenerator.java | 348 +++++++
.../post/RuntimeFilterPushDownVisitor.java | 19 +-
.../org/apache/doris/nereids/rules/RuleType.java | 1 +
.../mv/AbstractMaterializedViewRule.java | 20 +-
.../rules/exploration/mv/PartitionCompensator.java | 3 +-
.../nereids/rules/exploration/mv/Predicates.java | 525 ++++++++--
.../nereids/rules/expression/rules/AddMinMax.java | 25 +-
.../rules/rewrite/CheckMatchExpression.java | 7 +-
.../rules/rewrite/CollectLimitAboveConsumer.java | 58 ++
.../nereids/rules/rewrite/InferAggNotNull.java | 66 +-
.../nereids/rules/rewrite/InferJoinNotNull.java | 29 +-
.../rules/rewrite/PushDownJoinOnAssertNumRows.java | 102 +-
.../nereids/rules/rewrite/RewriteCteChildren.java | 16 +
.../rules/rewrite/RewriteSearchToSlots.java | 63 +-
.../trees/copier/LogicalPlanDeepCopier.java | 2 +-
.../nereids/trees/expressions/Expression.java | 3 +
.../nereids/trees/expressions/Placeholder.java | 8 +
.../nereids/trees/expressions/functions/Udf.java | 19 +-
.../functions/agg/DataSketchesHllUnionAgg.java | 113 ++
.../functions/executable/NumericArithmetic.java | 3 +
.../functions/executable/StringArithmetic.java | 68 ++
.../functions/scalar/HammingDistance.java | 78 ++
.../expressions/functions/scalar/Levenshtein.java | 76 ++
.../expressions/functions/scalar/StGeometries.java | 69 ++
.../functions/scalar/StNumGeometries.java | 68 ++
.../expressions/functions/scalar/StNumPoints.java | 68 ++
.../trees/expressions/functions/udf/JavaUdaf.java | 58 +-
.../expressions/functions/udf/JavaUdafBuilder.java | 2 +-
.../trees/expressions/functions/udf/JavaUdf.java | 17 +-
.../trees/expressions/functions/udf/JavaUdtf.java | 58 +-
.../expressions/functions/udf/JavaUdtfBuilder.java | 2 +-
.../expressions/functions/udf/PythonUdaf.java | 59 +-
.../functions/udf/PythonUdafBuilder.java | 2 +-
.../trees/expressions/functions/udf/PythonUdf.java | 17 +-
.../expressions/functions/udf/PythonUdtf.java | 58 +-
.../functions/udf/PythonUdtfBuilder.java | 2 +-
.../expressions/literal/DecimalV3Literal.java | 5 -
.../nereids/trees/expressions/literal/Literal.java | 4 -
.../visitor/AggregateFunctionVisitor.java | 5 +
.../expressions/visitor/ScalarFunctionVisitor.java | 25 +
.../nereids/trees/plans/algebra/Aggregate.java | 18 +-
.../trees/plans/commands/AnalyzeCommand.java | 6 +
.../plans/commands/CreateFunctionCommand.java | 61 +-
.../trees/plans/commands/ExecuteCommand.java | 141 ++-
.../trees/plans/commands/ShowFunctionsCommand.java | 9 +-
.../trees/plans/physical/RuntimeFilter.java | 10 +
.../apache/doris/nereids/types/VariantType.java | 3 +-
.../apache/doris/nereids/util/ExpressionUtils.java | 55 +-
.../doris/nereids/util/MoreFieldsThread.java | 5 +-
.../apache/doris/planner/GroupCommitBlockSink.java | 21 +
.../org/apache/doris/planner/OlapScanNode.java | 6 +
.../org/apache/doris/planner/OlapTableSink.java | 13 +-
.../org/apache/doris/planner/RuntimeFilter.java | 16 +-
.../apache/doris/qe/InsertStreamTxnExecutor.java | 21 +-
.../org/apache/doris/qe/MysqlConnectProcessor.java | 2 +-
.../apache/doris/qe/PreparedStatementContext.java | 10 +-
.../java/org/apache/doris/qe/SessionVariable.java | 30 +-
.../apache/doris/qe/ShortCircuitQueryContext.java | 10 +
.../java/org/apache/doris/qe/StmtExecutor.java | 12 +-
.../doris/qe/runtime/ThriftPlansBuilder.java | 29 +-
.../apache/doris/service/FrontendServiceImpl.java | 15 +-
.../org/apache/doris/statistics/AnalysisInfo.java | 10 +-
.../doris/statistics/AnalysisInfoBuilder.java | 11 +-
.../apache/doris/statistics/AnalysisManager.java | 3 +
.../apache/doris/statistics/BaseAnalysisTask.java | 23 +
.../doris/statistics/ExternalAnalysisTask.java | 16 +-
.../doris/statistics/FollowerColumnSender.java | 4 +-
.../apache/doris/statistics/OlapAnalysisTask.java | 12 +-
.../doris/statistics/StatisticsAutoCollector.java | 1 +
.../doris/statistics/query/QueryStatsRecorder.java | 212 ++++
.../doris/statistics/query/QueryStatsUtil.java | 6 +-
.../CdcStreamTableValuedFunction.java | 86 +-
.../doris/tablefunction/MetadataGenerator.java | 24 +-
.../apache/doris/catalog/CreateFunctionTest.java | 46 +
.../doris/catalog/DataSizeDisplayUtilTest.java | 124 +++
.../doris/catalog/FunctionToSqlConverterTest.java | 12 +-
.../doris/cloud/catalog/CloudUpgradeMgrTest.java | 221 ++++
.../common/proc/CloudProcVersionDisplayTest.java | 16 +-
.../common/proc/ColocationGroupProcDirTest.java | 294 ++++++
.../doris/common/proc/PartitionsProcDirTest.java | 61 ++
.../doris/common/proc/TabletHealthProcDirTest.java | 110 ++
.../apache/doris/common/util/LocationPathTest.java | 15 +
.../datasource/ExternalRowCountCacheTest.java | 61 +-
.../datasource/hive/HMSExternalTableTest.java | 140 +++
.../org/apache/doris/fs/FileSystemCacheTest.java | 139 +++
.../apache/doris/httpv2/rest/LoadActionTest.java | 445 +++++++-
.../doris/httpv2/rest/RestBaseControllerTest.java | 64 ++
.../util/StreamLoadRedirectDrainUtilTest.java | 394 +++++++
.../streaming/DataSourceConfigValidatorTest.java | 174 ++++
.../load/routineload/KafkaRoutineLoadJobTest.java | 25 +
.../java/org/apache/doris/metric/MetricsTest.java | 105 +-
.../apache/doris/nereids/mv/PredicatesTest.java | 389 ++++++-
.../doris/nereids/parser/NereidsParserTest.java | 24 +
.../nereids/postprocess/RuntimeFilterTest.java | 46 +
.../exploration/mv/PartitionCompensatorTest.java | 104 ++
.../rules/expression/ExpressionRewriteTest.java | 61 +-
.../nereids/rules/expression/FoldConstantTest.java | 20 +-
.../rules/rewrite/CheckMatchExpressionTest.java | 55 +
.../rewrite/CollectLimitAboveConsumerTest.java | 109 ++
.../rules/rewrite/CteLimitPushdownPlanTest.java | 167 +++
.../rules/rewrite/EliminateNotNullTest.java | 77 ++
.../nereids/rules/rewrite/InferAggNotNullTest.java | 81 ++
.../rules/rewrite/InferFilterNotNullTest.java | 28 +
.../rules/rewrite/InferJoinNotNullTest.java | 33 +
.../rewrite/PushDownJoinOnAssertNumRowsTest.java | 66 ++
.../RewriteCteChildrenLimitPushdownTest.java | 86 ++
.../rules/rewrite/RewriteSearchToSlotsTest.java | 109 +-
.../rules/rewrite/VariantPruningLogicTest.java | 58 +-
.../trees/copier/LogicalPlanDeepCopierTest.java | 11 +
.../scalar/StGeoComponentFunctionsTest.java | 136 +++
.../functions/udf/UdfVolatilityTest.java | 52 +
.../plans/commands/AnalyzeTableCommandTest.java | 70 +-
.../plans/commands/ShowFunctionsCommandTest.java | 33 +-
.../doris/planner/GroupCommitBlockSinkTest.java | 69 ++
.../doris/qe/InsertStreamTxnExecutorTest.java | 57 +
.../doris/statistics/AnalysisManagerTest.java | 102 ++
.../doris/statistics/FollowerColumnSenderTest.java | 28 +
.../doris/statistics/HMSAnalysisTaskTest.java | 46 +
.../doris/statistics/OlapAnalysisTaskTest.java | 113 ++
.../statistics/query/QueryStatsRecorderTest.java | 435 ++++++++
.../doris/statistics/util/StatisticsUtilTest.java | 4 +
fe/fe-sql-parser/README.md | 545 ++++++++++
fe/{fe-catalog => fe-sql-parser}/pom.xml | 81 +-
.../antlr4/org/apache/doris/nereids/DorisLexer.g4 | 1 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 10 +-
.../doris/nereids/errors/QueryParsingErrors.java | 0
.../nereids/exceptions/AnalysisException.java | 18 +-
.../doris/nereids/exceptions/ParseException.java | 2 +-
.../nereids/exceptions/SyntaxParseException.java | 0
.../nereids/parser/CaseInsensitiveStream.java | 0
.../org/apache/doris/nereids/parser/Origin.java | 0
.../apache/doris/nereids/parser/OriginAware.java} | 32 +-
.../doris/nereids/parser/ParseErrorListener.java | 0
.../apache/doris/nereids/parser/ParserUtils.java | 28 +-
.../apache/doris/nereids/parser/PostProcessor.java | 0
.../org/apache/doris/sqlparser/DorisSqlParser.java | 124 +++
.../apache/doris/sqlparser/DorisSqlParserCli.java | 237 +++++
.../apache/doris/sqlparser/DorisSqlParserTest.java | 75 ++
.../main/java/org/apache/doris/catalog/Type.java | 6 +
.../java/org/apache/doris/catalog/VariantType.java | 3 +-
fe/pom.xml | 1 +
.../postgresql/connection/PostgresConnection.java | 905 ++++++++++++++++
.../cdcclient/service/PipelineCoordinator.java | 14 +-
.../doris/cdcclient/sink/DorisBatchStreamLoad.java | 2 +-
.../deserialize/DebeziumJsonDeserializer.java | 46 +-
.../source/reader/AbstractCdcSourceReader.java | 23 +-
.../source/reader/JdbcIncrementalSourceReader.java | 106 +-
.../cdcclient/source/reader/SourceReader.java | 5 +
.../source/reader/mysql/MySqlSourceReader.java | 140 ++-
.../reader/postgres/PostgresSourceReader.java | 4 +
.../apache/doris/cdcclient/utils/ConfigUtil.java | 29 +-
.../source/fetch/PostgresScanFetchTask.java | 391 +++++++
.../deserialize/DebeziumJsonDeserializerTest.java | 76 ++
.../doris/cdcclient/utils/ConfigUtilTest.java | 61 +-
gensrc/proto/olap_file.proto | 20 +
gensrc/thrift/PlanNodes.thrift | 8 +-
.../data/ann_index_p0/ann_index_only_scan.out | 19 -
.../correctness/test_subquery_in_disjunction.out | 12 +
.../test_select_stddev_variance_window.out | 933 +++++++++--------
.../ddl/create_nestedtypes_with_schemachange.out | 12 +-
.../timestamptz/test_timestamptz_agg_functions.out | 3 +
.../basic-elements/data-types/map-md.out | 15 +
.../select/test_sqlserver_all_types_select.out | 16 +
.../data/function_p0/test_agg_foreach.out | 3 +-
.../data/function_p0/test_agg_foreach_notnull.out | 3 +-
...est_streaming_mysql_job_charset_and_strings.out | 39 +
.../cdc/test_streaming_mysql_job_composite_pk.out | 47 +
.../cdc/test_streaming_mysql_job_datetime_pk.out | 29 +
.../cdc/test_streaming_mysql_job_decimal_pk.out | 29 +
.../cdc/test_streaming_mysql_job_enum_set.out | 27 +
...est_streaming_mysql_job_id_gap_completeness.out | 21 +
.../test_streaming_mysql_job_integer_boundary.out | 31 +
.../cdc/test_streaming_mysql_job_json_types.out | 52 +
.../test_streaming_mysql_job_offset_earliest.out | 9 +
....out => test_streaming_mysql_job_partition.out} | 0
...ming_mysql_job_snapshot_with_concurrent_dml.out | 25 +
.../cdc/test_streaming_postgres_job_all_type.out | 4 +-
.../test_streaming_postgres_job_array_boundary.out | 29 +
.../test_streaming_postgres_job_composite_pk.out | 47 +
.../cdc/test_streaming_postgres_job_decimal_pk.out | 15 +
..._streaming_postgres_job_id_gap_completeness.out | 21 +
.../test_streaming_postgres_job_jsonb_types.out | 32 +
...ming_postgres_job_snapshot_historical_dates.out | 45 +
...g_postgres_job_snapshot_with_concurrent_dml.out | 25 +
.../cdc/test_streaming_postgres_job_uuid.out | 26 +
.../data/nereids_function_p0/agg_function/agg.out | 672 ++++++------
.../nereids_rules_p0/agg_strategy/agg_strategy.out | 28 +-
.../distinct_split/disitinct_split.out | 57 +-
.../limit_push_down/limit_push_down.out | 6 +-
.../limit_push_down/order_push_down.out | 6 +-
.../normalize_window_nullable_agg_test.out | 5 +-
.../data/nereids_syntax_p0/agg_4_phase.out | 2 +
.../nereids_syntax_p0/decoupled_runtime_filter.out | 23 +
.../nereids_syntax_p0/mv/aggregate/agg_sync_mv.out | 157 ++-
.../pythonudf_p0/test_pythonudf_file_protocol.out | 2 +
.../data/query_p0/aggregate/agg_nullable_2.out | 19 +-
.../data/query_p0/aggregate/aggregate.out | 4 +-
.../ddl/show_variables/show_variables_command.out | 8 +
...t_agg_after_nested_loop_join_local_exchange.out | 3 +
.../test_datasketches_hll_union_agg.out | 28 +
.../test_array_distance_functions.out | 10 +-
.../test_ipv4_ipv6_multi_not_equal.out | 36 +
...st_num_geometries_num_points_and_geometries.out | 336 ++++++
.../string_functions/test_string_all.out | 197 +++-
.../test_select_stddev_variance_window.out | 169 ++-
.../data/query_p0/stats/query_stats_test.out | 52 -
.../tpcds_sf100/noStatsRfPrune/query31.out | 18 +-
.../tpcds_sf100/no_stats_shape/query31.out | 18 +-
.../data/shape_check/tpcds_sf1000/hint/query11.out | 22 +-
.../data/shape_check/tpcds_sf1000/hint/query24.out | 12 +-
.../data/shape_check/tpcds_sf1000/hint/query4.out | 36 +-
.../data/shape_check/tpcds_sf1000/hint/query64.out | 26 +-
.../data/shape_check/tpcds_sf1000/hint/query74.out | 16 +-
.../data/shape_check/tpcds_sf1000/hint/query81.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query11.out | 22 +-
.../shape_check/tpcds_sf1000/shape/query24.out | 12 +-
.../shape_check/tpcds_sf1000/shape/query30.out | 4 +-
.../data/shape_check/tpcds_sf1000/shape/query4.out | 22 +-
.../shape_check/tpcds_sf1000/shape/query74.out | 16 +-
.../shape_check/tpcds_sf1000/shape/query81.out | 8 +-
.../tpcds_sf1000_nopkfk/shape/query11.out | 12 +-
.../tpcds_sf1000_nopkfk/shape/query24.out | 12 +-
.../tpcds_sf1000_nopkfk/shape/query30.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query4.out | 20 +-
.../tpcds_sf1000_nopkfk/shape/query74.out | 12 +-
.../tpcds_sf1000_nopkfk/shape/query81.out | 8 +-
.../shape_check/tpcds_sf10t_orc/shape/query11.out | 12 +-
.../shape_check/tpcds_sf10t_orc/shape/query18.out | 10 +-
.../shape_check/tpcds_sf10t_orc/shape/query31.out | 18 +-
.../shape_check/tpcds_sf10t_orc/shape/query4.out | 20 +-
.../shape_check/tpcds_sf10t_orc/shape/query54.out | 10 +-
.../shape_check/tpcds_sf10t_orc/shape/query74.out | 12 +-
.../tpch_sf1000/nostats_rf_prune/q8.out | 10 +-
.../data/shape_check/tpch_sf1000/rf_prune/q9.out | 16 +-
.../data/shape_check/tpch_sf1000/shape/q9.out | 14 +-
.../shape_check/tpch_sf1000/shape_no_stats/q8.out | 14 +-
regression-test/data/variant_p0/desc.out | 50 +-
regression-test/data/variant_p0/nested.out | 2 +-
regression-test/data/variant_p0/nested2.out | 8 +-
.../variant_p0/predefine/variant_hirachinal.out | 2 +-
.../variant_p0/test_variant_timestamptz_sparse.out | 7 +
.../org/apache/doris/regression/suite/Suite.groovy | 13 +
.../suites/ann_index_p0/ann_index_only_scan.groovy | 450 --------
...ann_index_only_scan_compound_debug_point.groovy | 159 +++
.../ann_index_only_scan_debug_point.groovy | 238 +++++
.../ann_index_only_scan_distance_expr.groovy | 207 ----
.../ann_index_only_scan_expr_debug_point.groovy | 105 ++
.../ann_index_only_scan_metric_direction.groovy | 229 ----
.../ann_range_search_pushdown_regression.groovy | 141 +++
...ge_search_source_index_status_regression.groovy | 84 ++
.../suites/audit/test_audit_log_behavior.groovy | 16 +-
.../suites/audit/test_audit_log_queue_time.groovy | 12 +-
.../multi_cluster/test_unfinished_txn_2pc.groovy | 116 +++
.../tablets/test_tablet_size_semantics.groovy | 131 +++
.../test_time_series_compaction_policy.groovy | 49 +-
.../test_subquery_in_disjunction.groovy | 81 +-
.../test_timestamptz_agg_functions.groovy | 37 +
.../basic-elements/data-types/map-md.groovy | 10 +
.../cache/test_file_cache_query_limit.groovy | 64 +-
.../hive/test_hive_query_cache.groovy | 11 +-
...test_iceberg_v3_row_lineage_query_insert.groovy | 63 +-
.../select/test_sqlserver_all_types_select.groovy | 14 +
.../test_audit_log_internal_query_failure.groovy | 7 +-
.../test_dml_when_one_be_down.groovy | 141 +++
..._streaming_mysql_job_charset_and_strings.groovy | 195 ++++
.../test_streaming_mysql_job_composite_pk.groovy | 198 ++++
.../test_streaming_mysql_job_datetime_pk.groovy | 153 +++
.../cdc/test_streaming_mysql_job_decimal_pk.groovy | 152 +++
.../cdc/test_streaming_mysql_job_enum_set.groovy | 182 ++++
..._streaming_mysql_job_id_gap_completeness.groovy | 159 +++
...est_streaming_mysql_job_integer_boundary.groovy | 165 +++
.../cdc/test_streaming_mysql_job_json_types.groovy | 176 ++++
...test_streaming_mysql_job_offset_earliest.groovy | 130 +++
.../cdc/test_streaming_mysql_job_partition.groovy | 166 +++
.../cdc/test_streaming_mysql_job_server_id.groovy | 133 +++
...t_streaming_mysql_job_snapshot_fat_split.groovy | 153 +++
...g_mysql_job_snapshot_with_concurrent_dml.groovy | 148 +++
.../cdc/test_streaming_postgres_job.groovy | 29 +-
...st_streaming_postgres_job_array_boundary.groovy | 185 ++++
...ng_postgres_job_async_split_pause_resume.groovy | 40 +-
...test_streaming_postgres_job_composite_pk.groovy | 198 ++++
.../test_streaming_postgres_job_decimal_pk.groovy | 130 +++
...eaming_postgres_job_drop_during_snapshot.groovy | 148 +++
...reaming_postgres_job_id_gap_completeness.groovy | 146 +++
.../test_streaming_postgres_job_jsonb_types.groovy | 186 ++++
.../test_streaming_postgres_job_publication.groovy | 124 ++-
..._streaming_postgres_job_slot_lsn_advance.groovy | 224 ++++
...treaming_postgres_job_snapshot_fat_split.groovy | 141 +++
...g_postgres_job_snapshot_historical_dates.groovy | 229 ++++
...ostgres_job_snapshot_with_concurrent_dml.groovy | 153 +++
...g_postgres_job_special_offset_restart_fe.groovy | 188 ++++
.../cdc/test_streaming_postgres_job_uuid.groovy | 176 ++++
.../cdc/tvf/test_cdc_stream_tvf_mysql.groovy | 83 +-
.../cdc/tvf/test_cdc_stream_tvf_postgres.groovy | 32 +
.../test_routine_load_error_info.groovy | 141 ++-
.../scripts/stream_load_redirect_chunked_e2e.py | 140 +++
...test_stream_load_fe_redirect_chunked_e2e.groovy | 117 +++
.../agg_strategy/agg_strategy.groovy | 1 -
.../test_cte_limit_pushdown.groovy | 175 ++++
.../mv/negative/negative_test.groovy | 7 +-
.../suites/nereids_syntax_p0/agg_4_phase.groovy | 25 +-
.../decoupled_runtime_filter.groovy | 134 +++
.../test_multicast_sink_multi_exchange.groovy | 96 ++
.../suites/point_query_p0/test_point_query.groovy | 101 ++
.../test_pythonudaf_object_types_inline.groovy | 184 ++++
.../test_pythonudf_file_protocol.groovy | 22 +
.../test_pythonudf_object_types_inline.groovy | 105 ++
.../test_pythonudtf_object_types_inline.groovy | 105 ++
.../suites/query_p0/aggregate/aggregate.groovy | 1 +
.../show_variables/show_variables_command.groovy | 8 +
.../fold_constant_numeric_arithmatic.groovy | 7 +
...gg_after_nested_loop_join_local_exchange.groovy | 130 +++
.../test_datasketches_hll_union_agg.groovy | 170 +++
.../test_ipv4_ipv6_multi_not_equal.groovy | 107 ++
...num_geometries_num_points_and_geometries.groovy | 544 ++++++++++
.../string_functions/test_string_all.groovy | 191 +++-
.../suites/query_p0/stats/query_stats_test.groovy | 120 ++-
.../suites/search/test_search_function.groovy | 13 +-
.../statistics/test_full_analyze_hot_value.groovy | 91 +-
.../suites/statistics/test_hot_value.groovy | 2 +-
.../test_storage_format_controls_encoding.groovy | 19 +-
.../variant_p0/predefine/variant_hirachinal.groovy | 8 +-
.../test_doris_24269_create_table_like.groovy | 59 ++
.../test_variant_timestamptz_sparse.groovy | 102 ++
.../suites/variant_p0/variant_hirachinal.groovy | 4 +-
.../suites/variant_p1/predefine/load.groovy | 3 +-
run-be-ut.sh | 14 +-
688 files changed, 37490 insertions(+), 6147 deletions(-)
copy be/src/{storage/index/inverted/inverted_index_stats.h =>
common/check.cpp} (77%)
create mode 100644 be/src/common/check.h
create mode 100644
be/src/exprs/aggregate/aggregate_function_datasketches_hll_union_agg.cpp
create mode 100644
be/src/exprs/aggregate/aggregate_function_datasketches_hll_union_agg.h
create mode 100644 be/src/exprs/function/function_hamming_distance.cpp
create mode 100644 be/src/exprs/function/function_levenshtein.cpp
create mode 100644 be/src/exprs/function/variant_inverted_index_search.cpp
create mode 100644 be/src/exprs/function/variant_inverted_index_search.h
create mode 100644
be/src/storage/segment/binary_plain_page_char_strip_pre_decoder.h
create mode 100644 be/test/AGENTS.md
create mode 100644 be/test/cloud/cloud_warm_up_manager_test.cpp
create mode 100644 be/test/common/check_test.cpp
create mode 100644 be/test/data/vec/columns/TIMESTAMPTZ(3).csv
create mode 100644
be/test/exprs/aggregate/agg_datasketches_hll_union_agg_test.cpp
create mode 100644 be/test/exprs/function/geo/functions_geo_test.cpp
create mode 100644 be/test/exprs/vcondition_expr_test.cpp
create mode 100644
be/test/io/cache/cached_remote_file_reader_lock_wait_test.cpp
create mode 100644 be/test/io/cache/cached_remote_file_reader_test.cpp
create mode 100644 be/test/io/fs/file_handle_cache_test.cpp
create mode 100644
be/test/runtime/workload_group/workload_group_metrics_test.cpp
delete mode 100644
be/test/storage/segment/segment_writer_full_encode_keys_test.cpp
create mode 100644 cloud/src/meta-service/meta_service_rate_limit_helper.cpp
create mode 100644 cloud/src/meta-service/meta_service_rate_limit_helper.h
create mode 100644 cloud/test/meta_service_helper_test.cpp
create mode 160000 contrib/datasketches-cpp
create mode 160000 doris-skills
create mode 100644
fe/fe-catalog/src/test/java/org/apache/doris/analysis/ExprEqualsTest.java
create mode 100644
fe/fe-catalog/src/test/java/org/apache/doris/analysis/LiteralExprCompareLiteralTest.java
create mode 100644
fe/fe-catalog/src/test/java/org/apache/doris/analysis/LiteralExprEqualsTest.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/catalog/DataSizeDisplayUtil.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/httpv2/util/StreamLoadRedirectDrainUtil.java
copy fe/fe-core/src/main/java/org/apache/doris/metric/{MetricVisitor.java =>
HistogramMetric.java} (51%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/CollectLimitAboveConsumer.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/DataSketchesHllUnionAgg.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/HammingDistance.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/Levenshtein.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/StGeometries.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/StNumGeometries.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/StNumPoints.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/query/QueryStatsRecorder.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/DataSizeDisplayUtilTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/cloud/catalog/CloudUpgradeMgrTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/proc/ColocationGroupProcDirTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/proc/PartitionsProcDirTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/proc/TabletHealthProcDirTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/fs/FileSystemCacheTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/httpv2/rest/RestBaseControllerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/httpv2/util/StreamLoadRedirectDrainUtilTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/CollectLimitAboveConsumerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/CteLimitPushdownPlanTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/EliminateNotNullTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/RewriteCteChildrenLimitPushdownTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/scalar/StGeoComponentFunctionsTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/GroupCommitBlockSinkTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/qe/InsertStreamTxnExecutorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/statistics/query/QueryStatsRecorderTest.java
create mode 100644 fe/fe-sql-parser/README.md
copy fe/{fe-catalog => fe-sql-parser}/pom.xml (58%)
rename fe/{fe-core =>
fe-sql-parser}/src/main/antlr4/org/apache/doris/nereids/DorisLexer.g4 (99%)
rename fe/{fe-core =>
fe-sql-parser}/src/main/antlr4/org/apache/doris/nereids/DorisParser.g4 (99%)
rename fe/{fe-core =>
fe-sql-parser}/src/main/java/org/apache/doris/nereids/errors/QueryParsingErrors.java
(100%)
rename fe/{fe-core =>
fe-sql-parser}/src/main/java/org/apache/doris/nereids/exceptions/AnalysisException.java
(84%)
rename fe/{fe-core =>
fe-sql-parser}/src/main/java/org/apache/doris/nereids/exceptions/ParseException.java
(99%)
rename fe/{fe-core =>
fe-sql-parser}/src/main/java/org/apache/doris/nereids/exceptions/SyntaxParseException.java
(100%)
rename fe/{fe-core =>
fe-sql-parser}/src/main/java/org/apache/doris/nereids/parser/CaseInsensitiveStream.java
(100%)
rename fe/{fe-core =>
fe-sql-parser}/src/main/java/org/apache/doris/nereids/parser/Origin.java (100%)
copy
fe/{fe-core/src/main/java/org/apache/doris/nereids/exceptions/CastException.java
=>
fe-sql-parser/src/main/java/org/apache/doris/nereids/parser/OriginAware.java}
(56%)
rename fe/{fe-core =>
fe-sql-parser}/src/main/java/org/apache/doris/nereids/parser/ParseErrorListener.java
(100%)
rename fe/{fe-core =>
fe-sql-parser}/src/main/java/org/apache/doris/nereids/parser/ParserUtils.java
(77%)
rename fe/{fe-core =>
fe-sql-parser}/src/main/java/org/apache/doris/nereids/parser/PostProcessor.java
(100%)
create mode 100644
fe/fe-sql-parser/src/main/java/org/apache/doris/sqlparser/DorisSqlParser.java
create mode 100644
fe/fe-sql-parser/src/main/java/org/apache/doris/sqlparser/DorisSqlParserCli.java
create mode 100644
fe/fe-sql-parser/src/test/java/org/apache/doris/sqlparser/DorisSqlParserTest.java
create mode 100644
fs_brokers/cdc_client/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java
create mode 100644
fs_brokers/cdc_client/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresScanFetchTask.java
create mode 100644
fs_brokers/cdc_client/src/test/java/org/apache/doris/cdcclient/source/deserialize/DebeziumJsonDeserializerTest.java
delete mode 100644 regression-test/data/ann_index_p0/ann_index_only_scan.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_mysql_job_charset_and_strings.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_mysql_job_composite_pk.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_mysql_job_datetime_pk.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_mysql_job_decimal_pk.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_mysql_job_enum_set.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_mysql_job_id_gap_completeness.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_mysql_job_integer_boundary.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_mysql_job_json_types.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_mysql_job_offset_earliest.out
copy
regression-test/data/job_p0/streaming_job/cdc/{test_streaming_postgres_job_partition.out
=> test_streaming_mysql_job_partition.out} (100%)
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_mysql_job_snapshot_with_concurrent_dml.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_postgres_job_array_boundary.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_postgres_job_composite_pk.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_postgres_job_decimal_pk.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_postgres_job_id_gap_completeness.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_postgres_job_jsonb_types.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_postgres_job_snapshot_historical_dates.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_postgres_job_snapshot_with_concurrent_dml.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_postgres_job_uuid.out
create mode 100644
regression-test/data/nereids_syntax_p0/decoupled_runtime_filter.out
create mode 100644
regression-test/data/query_p0/join/test_agg_after_nested_loop_join_local_exchange.out
create mode 100644
regression-test/data/query_p0/sql_functions/aggregate_functions/test_datasketches_hll_union_agg.out
create mode 100644
regression-test/data/query_p0/sql_functions/ip_functions/test_ipv4_ipv6_multi_not_equal.out
create mode 100644
regression-test/data/query_p0/sql_functions/spatial_functions/test_st_num_geometries_num_points_and_geometries.out
delete mode 100644 regression-test/data/query_p0/stats/query_stats_test.out
create mode 100644
regression-test/data/variant_p0/test_variant_timestamptz_sparse.out
delete mode 100644
regression-test/suites/ann_index_p0/ann_index_only_scan.groovy
create mode 100644
regression-test/suites/ann_index_p0/ann_index_only_scan_compound_debug_point.groovy
create mode 100644
regression-test/suites/ann_index_p0/ann_index_only_scan_debug_point.groovy
delete mode 100644
regression-test/suites/ann_index_p0/ann_index_only_scan_distance_expr.groovy
create mode 100644
regression-test/suites/ann_index_p0/ann_index_only_scan_expr_debug_point.groovy
delete mode 100644
regression-test/suites/ann_index_p0/ann_index_only_scan_metric_direction.groovy
create mode 100644
regression-test/suites/ann_index_p0/ann_range_search_pushdown_regression.groovy
create mode 100644
regression-test/suites/ann_index_p0/ann_range_search_source_index_status_regression.groovy
create mode 100644
regression-test/suites/cloud_p0/multi_cluster/test_unfinished_txn_2pc.groovy
create mode 100644
regression-test/suites/cloud_p0/tablets/test_tablet_size_semantics.groovy
create mode 100644
regression-test/suites/fault_injection_p0/test_dml_when_one_be_down.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_charset_and_strings.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_composite_pk.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_datetime_pk.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_decimal_pk.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_enum_set.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_id_gap_completeness.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_integer_boundary.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_json_types.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_offset_earliest.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_partition.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_server_id.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_snapshot_fat_split.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_snapshot_with_concurrent_dml.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_array_boundary.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_composite_pk.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_decimal_pk.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_drop_during_snapshot.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_id_gap_completeness.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_jsonb_types.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_slot_lsn_advance.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_snapshot_fat_split.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_snapshot_historical_dates.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_snapshot_with_concurrent_dml.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_special_offset_restart_fe.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_uuid.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/scripts/stream_load_redirect_chunked_e2e.py
create mode 100644
regression-test/suites/load_p0/stream_load/test_stream_load_fe_redirect_chunked_e2e.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/cte_limit_pushdown/test_cte_limit_pushdown.groovy
create mode 100644
regression-test/suites/nereids_syntax_p0/decoupled_runtime_filter.groovy
create mode 100644
regression-test/suites/nereids_syntax_p0/distribute/test_multicast_sink_multi_exchange.groovy
create mode 100644
regression-test/suites/pythonudaf_p0/test_pythonudaf_object_types_inline.groovy
create mode 100644
regression-test/suites/pythonudf_p0/test_pythonudf_object_types_inline.groovy
create mode 100644
regression-test/suites/pythonudtf_p0/test_pythonudtf_object_types_inline.groovy
create mode 100644
regression-test/suites/query_p0/join/test_agg_after_nested_loop_join_local_exchange.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/aggregate_functions/test_datasketches_hll_union_agg.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/ip_functions/test_ipv4_ipv6_multi_not_equal.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/spatial_functions/test_st_num_geometries_num_points_and_geometries.groovy
create mode 100644
regression-test/suites/variant_p0/test_doris_24269_create_table_like.groovy
create mode 100644
regression-test/suites/variant_p0/test_variant_timestamptz_sparse.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
