This is an automated email from the ASF dual-hosted git repository.
panxiaolei pushed a change to branch refactor_rf
in repository https://gitbox.apache.org/repos/asf/doris.git
omit 1eafeb11876 fix case
omit a65b45785cb update fix
omit c07f0fc034a add rpc fail test and eof test
omit 8566f1463ce test RuntimeFilterMergeControllerEntity (#48678)
omit bea5d97b55c test RuntimeFilterMgr (#48672)
omit 5ba23190eaa format (#48658)
omit da8932c743a test (#48630)
omit c9549824efb test rf utils (#48615)
omit 59fde894fe0 add more ut of roles
omit a9c28a16288 test in or bloom (#48596)
omit 2292611437b fix UT (#48591)
omit 575226dee1d fix compile fail and format
omit e7ceb5d39c1 [rf](ut) test minmax/bitmap filter (#48579)
omit 331f9de9d94 fix coredump
omit cfee9c7c084 [runtime filter](UT) test bloom filter (#48575)
omit f9a3d901399 add more test and some fix
omit 718e4ff2707 [runtime filter](UT) test in filter (#48562)
omit 2a85ea0d89d [refactor](runtime filter) Refine null property in runtime
filter (#48534)
omit ff177645a35 some fix and add ut
omit e37a3a41b70 refactor of RuntimeFilterSlots
add 3f85ad6d75c [enchement](schema change)Standardize the behavior after a
table schema change. (#47471)
add 3dbbc99919e [opt](fe) Try to avoid `meta out of date` log when
non-master fe starting (#48395)
add 04f2e3311e5 [feature](k8s) add kerberos support for doris-operator
(#48183)
add 217e365e5c0 [Chore](client) Do not log in thrift exception when
ADDRESS_SANITIZER is defined (#48430)
add 8da8d01c5d9 [bug](auto partition) Fix be crash with single replica
insert (#48101)
add e44f45aa2bd [Improve](cloud) support caching SchemaCloudDictionary in
BE side (#47629)
add 3a723b05a4f [fix](Outfile) add two fields to `SELECT INTO OUTFILE`
(#48144)
add abe26b9b690 [Feat](Nereids) support alter system set load errors hub
and refactor alter system (#48252)
add 2835a521949 [fix](load) Fix import failure when the stream load
parameter specifies Transfer-Encoding:chunked (#48196)
add c9394ec7e26 [fix](regression-test) delete case about spark hudi jni
reader (#48418)
add bfec79b2e8a [fix](regression)Turn auto analyze off before run analyze
test. (#48414)
add e021a6a0158 [Improvement](column) add santy check and optimize for
ColumnStr<T>::replicate (#47964)
add 02a7640068f [Fix](case) exclude
`test_primary_key_partial_update_broker_load` when
`random_add_cluster_keys_for_mow=true` (#48454)
add 9e1aa777ff4 [compaction](config) Add a config to control whether to
prune rows with delete sign=1 in base compaction (#48241)
add fe21189c185 [Opt](merge-on-write) Check delete bitmap cache after
writing it (#48233)
add 3ea1b7c5c6f [fix](set variable)Set local session variable when set
global variable on Observer. (#48468)
add 9c66121027e [improvement](thrift) Limit max cached client size for BE
thrift connection to master FE. (#43973)
add 2e1268a6a3d [chore](config)Clarify and Improve sys_log_roll_num
Parameter Description (#48442)
add 54bb19f1fbd [enhance](paimon) opt count pushdown for paimon and
refactor be logic (#46911)
add f97b23cb778 [fix](p2) fix the failed of cold_heat_separation_p2
(#48199)
add 2f1691c7049 [fix](broker) fix fd always timeout (#48494)
add 69a6a715301 [Opt](partial update) Add some cases for partial update
(#48161)
add e2a9897b831 [refactor](result sink) refactor result writers (#48368)
add 384165405a6 [fix](index build) Correct inverted index behavior after
dynamically adding a column (#48389)
add c2a23e13f65 [BE](ut) add datatype serde be ut test case (#48431)
add b06b3c5a456 [enhancement](threadpool) reduce thread pool for arrow
flight and spill io threads (#48530)
add f10780bb24e [fix](case) fix insert_group_commit_into_unique_sync_mode
(#48384)
add c864779b5f3 [fix](regression) fix cache p0 regression tests (#48515)
add 6b88fdd4dbc [opt](fe) Avoid load `retrying_service_config.json` multi
times for class MetaServiceClient (#48487)
add d9d45198ea4 [fix](memory) Fix `SwitchResourceContext` check attach
task (#48429)
add 09939fd69d5 [improve](binlog) Download binlogs with persistent
connection (#48467)
add e29e995ff71 [fix](group commit) group commit support generated column
(#48538)
add f1e6de3f442 [enhancement](schema-change) Schema change wait lock for a
while when there are inverted index being built or cooldown running on base
tablet (#47958)
add 7bd1ed2f975 [fix](cloud) fix evict in advance only last for short time
(#47892)
add fa7599627d2 [fix](binlog) avoid adding acqurie_md5 param when
enable_download_md5… (#48573)
add 87c6a003cea [performance](mow) async calc delete bitmap in add_segment
(#48156)
add aed3e84cd33 [Feature](orc-reader) Implement new merge io facility for
orc reader. (#45966)
add 0a0d4342963 [fix](jdbc test) fix some jdbc catalog test when cloud
mode (#48559)
add 8def32db1c3 [fix](jdbc catalog) Use factory methods to return mapped
types instead 2 (#48541)
add 8d084c12c77 [fix](Outfile) add regression test for `outfile` (#48488)
add f1193f47b91 [enhancement](test) add flight record script/test to
analyze memory consume (#48472)
add 97ad3e4e5e3 [Feat](Nereids) support show tables command (#48505)
add d9dfd7f32fe [improve](ut) add ut for column_array (#45827)
add 5a938791d98 [Enhancement] (nereids)implement
alterCatalogPropertiesCommand in nereids (#45164)
add 1304867d077 [fix](nereids) create/alter view column name should not
force cast to lower case (#48569)
add 2dfa817a905 [util](column) add check_and_get_column_ptr to cast
ColumnPtr (#48306)
add 17a32f5469d [Refactor](pipeline) remove unless member in
schema_scan_operator.cpp (#48588)
add d36544cad0e [opt](profile) Optimization for profile file format
(#48496)
add 7ad5d5b4c2b [fix](function) Percentil func core when percent args is
non nullable negative number (#48563)
add b3b6e369d4e [chore](http) add HttpClient::execute debug log (#48595)
add aafa227cf84 [fix](result sink) Fix empty sender if exists (#48614)
add ccbc3286a92 [enhance](mtmv) insert overwrite of mtmv force drop
partition (#48074)
add b87c17c3b20 [case](auth)fix no such property jdbcUser (#48622)
add e1c6d8d6ab1 [fix](heartbeat) avoid failure immediately due to
connection reset (#48444)
add ae78e195915 [fix](memtable) revert #47860 and fix #47610 (#48489)
add 220d00fc9a6 [improve](load) improve error message "unknown load_id"
(#47509)
add db78a1194fa [fix](s3) support chinacloudapi endpoint for azure (#47703)
add 7b385c11faa [fix](log) Fix s3_rate_limiter.cpp LOG incomplete (#48440)
add 09cbc482fb1 [Fix](case) Fix `test_skip_calc_between_segments` when
`force_olap_table_replication_num=3` (#48519)
add ad032c4e04f [chore](binlog) add ingesting/downloading binlog latency
metrics (#48599)
add 52bf70d246e [chore](binlog) Save tablet delta rows in UpsertRecord
(#48550)
add 7e3c475d51b [improve](restore) Link existing rowset files with source
rowset id (#48435)
add 9b94385d8ba [fix](cloud) fix filecache warmup crash due to spurious
wakeup (#48623)
add b5955394077 [fix](arrow) Fix UT `DataTypeSerDeArrowTest` of Date type
(#48398)
add bb0f5efca8e [fix](nereids)fix unstable test_correlated_filter_removed
case (#48520)
add 062301609d9 [fix](regression) topn-filter unstable
case：test_map_select_with_limit (#48598)
add c142fc0fc7d [opt](nereids) do not fetch partition col stats (#48354)
add b38a3ff8de1 [Fix](case) Fix case
`test_partial_update_with_delete_col_in_publish` (#48632)
add 987bcc92157 [Fix](mow) Fix some logs for mow (#48523)
add 54e7e94b89b [Fix](cloud) Should consider tablet state change whether
to skip `sync_rowsets` in publish phase (#48400)
add 49145612619 [fix](nereids) derive sum() column stats as UNKNOWN
(#48397)
add 5b12f0e5d0d [Enhancement] (nereids) support show data command (#48629)
add b4f8fcd44da [Enhancement] (nereids)implement showStoragePolicyCommand
in nereids (#44393)
add 81886fa476f [Enhancement] (nereids) support show column histogram
command (#48587)
add 153c94bb21f [enhance](mtmv)mv_infos not hold read lock of tables
(#47415)
add 6a36a9f32e6 [fix](columns) fix bug found by UT and add regression test
(#48554)
add a586d3c7fe2 [test](beut) add agg beut testing util (#48647)
add 4d21c76e558 [fix](Nereids) nested window function with order by raise
exception (#48492)
add e24ab70e921 [improve](tablet schema) opt TabletIndex mem (#48273)
add 02647304e27 [fix](Nereids) divide const folding for decimalv3 return
type is not correct (#48641)
add 0f1aca07588 [improvement](statistics)Add session variable for
partition sample count. (#48218)
add 016a043f41b [fix](regression)Fix insert p2 cases. (#48636)
add 932b96673ac [opt](mtmv) metadata cache of external table no longer be
refreshed before run async mv task (#48172)
add 03962f28e44 [fix](build)fix parquet add cast_set build error. (#46135)
add 9398d2ae63b [fix](icu) enforce MAX_WORD_LEN constraint for ICU
tokenized terms (#48381)
add 49033fd2a48 Revert "[fix](nereids) Add unique id to non foldable
expression (#481… (#48688)
add 528388aaea8 [fix](hudi) Set Hadoop Hudi Jni reader as default (#48602)
add 48fa09096d6 [test](kerberos)Add hdfs(tvf),outfile and export test
(#48433)
add 6fee498e011 [fix](function) fix the function elt (#48701)
add 1182402e62c [fix](jsonb) fix invalid jsonb value write into segment
file which make select core (#48625)
add fb5357e61a1 [fix](test) Remove unnecessary checks for sp test (#48611)
add facc2cef561 [Enchancement](profile) More accurate display of
predicates on storage layer (#48650)
add 7debd77fca6 [fix](arrow-flight-sql) Add java parsing datetime type in
arrow flight sql sample (#48578)
add 80a6e2ac371 [fix](memory) Fix `SwitchResourceContext` when thread
context no attach task (#48671)
add 7a85b6d20f8 [Chore](column) fix wrong chars size on
TransformerToStringOneArgument and add more check (#48545)
add 6fbe9d4e8e4 [fix] (inverted index) Fix UTF-8 4-byte truncation issue
and add configuration to control correct term writing (#48657)
add df5d8c1beb7 [ut](spill) add UT for partitioned hash join (#48432)
add 6cf12bd3e46 refactor of RuntimeFilterSlots
add 835d84a15c1 some fix and add ut
add 2d8679480ac [refactor](runtime filter) Refine null property in runtime
filter (#48534)
add 626fcf3b64f [runtime filter](UT) test in filter (#48562)
add 20e1f6ebbf7 add more test and some fix
add 5dc9fd1eb30 [runtime filter](UT) test bloom filter (#48575)
add 551a3c5f15c fix coredump
add ecc64faa8a8 [rf](ut) test minmax/bitmap filter (#48579)
add 73ebbecca8b fix compile fail and format
add 1dba2c07fc6 fix UT (#48591)
add b717414fc53 test in or bloom (#48596)
add 9b0d3138a96 add more ut of roles
add fdcdccb4dec test rf utils (#48615)
add 343afdbaa27 test (#48630)
add 63c2ac04f5d format (#48658)
add e5df476a793 test RuntimeFilterMgr (#48672)
add ee1a212069b test RuntimeFilterMergeControllerEntity (#48678)
add 4f6345199ae add rpc fail test and eof test
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 (1eafeb11876)
\
N -- N -- N refs/heads/refactor_rf (4f6345199ae)
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:
LICENSE.txt | 8 +
be/src/agent/utils.cpp | 13 +-
be/src/agent/utils.h | 2 +
be/src/apache-orc | 2 +-
.../cloud/cloud_engine_calc_delete_bitmap_task.cpp | 20 +-
.../cloud/cloud_engine_calc_delete_bitmap_task.h | 3 +
be/src/cloud/cloud_meta_mgr.cpp | 78 +-
be/src/cloud/cloud_meta_mgr.h | 4 +
be/src/cloud/cloud_schema_change_job.cpp | 19 +-
be/src/cloud/cloud_storage_engine.cpp | 5 +
be/src/cloud/cloud_storage_engine.h | 5 +
be/src/cloud/cloud_tablet.cpp | 21 +
be/src/cloud/cloud_tablet.h | 3 +
be/src/cloud/cloud_warm_up_manager.cpp | 9 +-
be/src/cloud/pb_convert.cpp | 8 +
be/src/cloud/schema_cloud_dictionary_cache.cpp | 226 ++
be/src/cloud/schema_cloud_dictionary_cache.h | 101 +
be/src/clucene | 2 +-
be/src/common/config.cpp | 14 +-
be/src/common/config.h | 14 +-
be/src/exec/schema_scanner.h | 3 +-
be/src/http/action/download_binlog_action.cpp | 13 +
be/src/http/action/stream_load.cpp | 1 +
be/src/http/http_client.cpp | 37 +-
be/src/http/http_client.h | 5 +
be/src/io/cache/block_file_cache.cpp | 58 +-
be/src/io/cache/block_file_cache.h | 15 +-
be/src/io/fs/azure_obj_storage_client.cpp | 14 +-
be/src/io/fs/stream_load_pipe.h | 10 +
be/src/olap/base_tablet.cpp | 18 +-
be/src/olap/base_tablet.h | 10 +-
be/src/olap/iterators.h | 2 +-
be/src/olap/memtable_writer.cpp | 10 +-
be/src/olap/rowset/beta_rowset_reader.cpp | 5 +-
be/src/olap/rowset/beta_rowset_reader.h | 2 +-
be/src/olap/rowset/beta_rowset_writer.cpp | 13 +-
be/src/olap/rowset/beta_rowset_writer.h | 1 +
be/src/olap/rowset/rowset_reader.h | 2 +-
.../rowset/segment_v2/hierarchical_data_reader.h | 2 +-
.../inverted_index/analyzer/icu/ICUTokenizer.cpp | 3 +-
.../rowset/segment_v2/inverted_index_writer.cpp | 1 +
.../rowset/segment_v2/lazy_init_segment_iterator.h | 5 +-
be/src/olap/rowset/segment_v2/segment_iterator.h | 16 +-
be/src/olap/schema_change.cpp | 14 +-
be/src/olap/snapshot_manager.cpp | 8 +-
be/src/olap/tablet.cpp | 5 +-
be/src/olap/tablet_column_object_pool.cpp | 73 +-
be/src/olap/tablet_column_object_pool.h | 17 +-
be/src/olap/tablet_meta.cpp | 12 +-
be/src/olap/tablet_meta.h | 1 +
be/src/olap/tablet_reader.cpp | 3 +-
be/src/olap/tablet_reader.h | 2 +-
be/src/olap/tablet_schema.cpp | 80 +-
be/src/olap/tablet_schema.h | 18 +-
be/src/olap/tablet_schema_cache.cpp | 2 +-
be/src/olap/task/index_builder.cpp | 28 +-
be/src/olap/task/index_builder.h | 18 +-
be/src/pipeline/exec/hashjoin_build_sink.h | 10 +-
be/src/pipeline/exec/hashjoin_probe_operator.h | 6 +-
be/src/pipeline/exec/operator.h | 8 +-
.../exec/partitioned_hash_join_probe_operator.cpp | 10 +-
.../exec/partitioned_hash_join_probe_operator.h | 7 +-
.../exec/partitioned_hash_join_sink_operator.cpp | 2 +-
.../exec/partitioned_hash_join_sink_operator.h | 6 +-
be/src/pipeline/exec/result_file_sink_operator.cpp | 11 +-
be/src/pipeline/exec/result_file_sink_operator.h | 4 +-
be/src/pipeline/exec/result_sink_operator.cpp | 67 +-
be/src/pipeline/exec/result_sink_operator.h | 14 +-
be/src/pipeline/exec/scan_operator.cpp | 5 +
be/src/pipeline/exec/schema_scan_operator.cpp | 7 +-
be/src/pipeline/exec/schema_scan_operator.h | 2 -
be/src/pipeline/exec/spill_utils.h | 11 +-
be/src/runtime/buffer_control_block.cpp | 495 ----
be/src/runtime/buffer_control_block.h | 184 --
be/src/runtime/fragment_mgr.cpp | 4 +-
be/src/runtime/fragment_mgr.h | 3 +-
be/src/runtime/load_channel.cpp | 1 +
be/src/runtime/load_channel.h | 2 -
be/src/runtime/load_channel_mgr.cpp | 7 +-
be/src/runtime/memory/cache_policy.h | 9 +-
be/src/runtime/memory/mem_tracker_limiter.cpp | 4 +-
be/src/runtime/result_block_buffer.cpp | 245 ++
be/src/runtime/result_block_buffer.h | 125 +
be/src/runtime/result_buffer_mgr.cpp | 134 +-
be/src/runtime/result_buffer_mgr.h | 30 +-
be/src/runtime/runtime_state.h | 5 -
be/src/runtime/snapshot_loader.cpp | 887 ++++---
be/src/runtime/snapshot_loader.h | 3 +
be/src/runtime/tablets_channel.cpp | 14 +-
be/src/runtime/thread_context.cpp | 29 +-
be/src/runtime/thread_context.h | 5 +-
be/src/runtime/types.cpp | 20 +-
be/src/runtime/types.h | 3 +-
.../arrow_flight/arrow_flight_batch_reader.cpp | 19 +-
be/src/service/backend_service.cpp | 54 +-
be/src/service/internal_service.cpp | 47 +-
be/src/service/point_query_executor.cpp | 39 +-
be/src/util/arrow/block_convertor.cpp | 286 +--
be/src/util/arrow/row_batch.cpp | 2 -
be/src/util/bit_util.h | 4 +-
be/src/util/jsonb_document.h | 4 +-
be/src/util/jsonb_utils.h | 2 +-
be/src/util/jsonb_writer.h | 3 +-
be/src/util/rle_encoding.h | 14 +-
be/src/util/s3_util.cpp | 11 +-
be/src/util/stopwatch.hpp | 11 +-
.../aggregate_function_percentile.h | 1 +
be/src/vec/columns/column.cpp | 4 +-
be/src/vec/columns/column.h | 34 +-
be/src/vec/columns/column_array.cpp | 147 +-
be/src/vec/columns/column_array.h | 5 -
be/src/vec/columns/column_decimal.cpp | 10 +-
be/src/vec/columns/column_map.h | 1 -
be/src/vec/columns/column_nullable.h | 3 -
be/src/vec/columns/column_object.cpp | 2 +-
be/src/vec/columns/column_string.cpp | 100 +-
be/src/vec/columns/column_string.h | 18 +
be/src/vec/columns/column_struct.h | 1 -
be/src/vec/columns/columns_number.h | 1 -
be/src/vec/core/field.cpp | 6 +-
be/src/vec/data_types/data_type_time_v2.h | 4 +-
.../data_types/serde/data_type_date64_serde.cpp | 33 +-
.../vec/data_types/serde/data_type_date64_serde.h | 7 +
.../data_types/serde/data_type_decimal_serde.cpp | 2 +-
.../vec/data_types/serde/data_type_hll_serde.cpp | 2 +-
.../serde/data_type_quantilestate_serde.h | 6 +-
be/src/vec/exec/format/column_type_convert.cpp | 184 +-
be/src/vec/exec/format/column_type_convert.h | 420 +++-
be/src/vec/exec/format/json/new_json_reader.cpp | 51 +-
be/src/vec/exec/format/json/new_json_reader.h | 4 +
be/src/vec/exec/format/orc/orc_file_reader.cpp | 106 +
be/src/vec/exec/format/orc/orc_file_reader.h | 88 +
be/src/vec/exec/format/orc/vorc_reader.cpp | 227 +-
be/src/vec/exec/format/orc/vorc_reader.h | 86 +-
.../vec/exec/format/parquet/arrow_memory_pool.cpp | 3 +-
be/src/vec/exec/format/parquet/arrow_memory_pool.h | 3 +-
.../vec/exec/format/parquet/bool_plain_decoder.cpp | 8 +-
.../vec/exec/format/parquet/bool_plain_decoder.h | 5 +
.../vec/exec/format/parquet/bool_rle_decoder.cpp | 5 +-
be/src/vec/exec/format/parquet/bool_rle_decoder.h | 3 +
.../format/parquet/byte_array_dict_decoder.cpp | 11 +-
.../exec/format/parquet/byte_array_dict_decoder.h | 4 +-
.../format/parquet/byte_array_plain_decoder.cpp | 4 +-
.../exec/format/parquet/byte_array_plain_decoder.h | 4 +-
.../format/parquet/byte_stream_split_decoder.cpp | 4 +-
.../format/parquet/byte_stream_split_decoder.h | 2 +
be/src/vec/exec/format/parquet/decoder.cpp | 3 +-
be/src/vec/exec/format/parquet/decoder.h | 5 +-
.../exec/format/parquet/delta_bit_pack_decoder.h | 48 +-
.../format/parquet/fix_length_dict_decoder.hpp | 8 +-
.../exec/format/parquet/fix_length_plain_decoder.h | 4 +-
be/src/vec/exec/format/parquet/level_decoder.cpp | 10 +-
be/src/vec/exec/format/parquet/level_decoder.h | 3 +-
.../exec/format/parquet/parquet_column_convert.cpp | 13 +-
.../exec/format/parquet/parquet_column_convert.h | 50 +-
be/src/vec/exec/format/parquet/parquet_common.cpp | 8 +-
be/src/vec/exec/format/parquet/parquet_common.h | 5 +-
be/src/vec/exec/format/parquet/parquet_pred_cmp.h | 5 +-
.../vec/exec/format/parquet/parquet_thrift_util.h | 4 +-
be/src/vec/exec/format/parquet/schema_desc.cpp | 17 +-
be/src/vec/exec/format/parquet/schema_desc.h | 6 +-
.../parquet/vparquet_column_chunk_reader.cpp | 3 +-
.../format/parquet/vparquet_column_chunk_reader.h | 3 +-
.../exec/format/parquet/vparquet_column_reader.cpp | 5 +-
.../exec/format/parquet/vparquet_column_reader.h | 3 +-
.../exec/format/parquet/vparquet_file_metadata.cpp | 3 +-
.../exec/format/parquet/vparquet_file_metadata.h | 3 +-
.../exec/format/parquet/vparquet_group_reader.cpp | 5 +-
.../exec/format/parquet/vparquet_group_reader.h | 4 +-
.../exec/format/parquet/vparquet_page_index.cpp | 7 +-
.../vec/exec/format/parquet/vparquet_page_index.h | 7 +-
.../exec/format/parquet/vparquet_page_reader.cpp | 6 +-
.../vec/exec/format/parquet/vparquet_page_reader.h | 12 +-
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 7 +-
be/src/vec/exec/format/parquet/vparquet_reader.h | 6 +-
be/src/vec/exec/format/table/hudi_jni_reader.cpp | 10 +-
be/src/vec/exec/format/table/iceberg_reader.cpp | 43 +-
be/src/vec/exec/format/table/iceberg_reader.h | 24 +-
be/src/vec/exec/format/table/paimon_jni_reader.cpp | 23 +-
be/src/vec/exec/format/table/paimon_jni_reader.h | 1 +
be/src/vec/exec/format/table/paimon_reader.cpp | 28 +-
be/src/vec/exec/format/table/paimon_reader.h | 26 +-
be/src/vec/exec/format/table/table_format_reader.h | 57 +-
.../format/table/transactional_hive_reader.cpp | 15 +-
.../exec/format/table/transactional_hive_reader.h | 13 +-
be/src/vec/exec/scan/new_olap_scanner.cpp | 5 +-
be/src/vec/exec/scan/new_olap_scanner.h | 3 -
be/src/vec/exec/scan/vfile_scanner.cpp | 13 +-
.../exprs/table_function/vexplode_json_array.cpp | 2 +-
.../exprs/table_function/vexplode_json_object.cpp | 4 +-
be/src/vec/exprs/table_function/vexplode_map.cpp | 2 +-
be/src/vec/exprs/table_function/vposexplode.cpp | 2 +-
be/src/vec/exprs/vexpr_context.cpp | 6 +
.../vec/functions/array/function_array_element.h | 2 +-
.../vec/functions/array/function_array_flatten.cpp | 10 +-
be/src/vec/functions/array/function_array_index.h | 2 +-
be/src/vec/functions/array/function_array_map.h | 2 +-
be/src/vec/functions/array/function_array_remove.h | 2 +-
be/src/vec/functions/array/function_array_set.h | 2 +-
be/src/vec/functions/date_time_transforms.h | 2 +
be/src/vec/functions/function_cast.h | 4 +-
be/src/vec/functions/function_decode_varchar.cpp | 1 +
be/src/vec/functions/function_helpers.cpp | 2 +-
be/src/vec/functions/function_helpers.h | 2 +-
be/src/vec/functions/function_ip.h | 3 +
be/src/vec/functions/function_jsonb.cpp | 17 +-
be/src/vec/functions/function_reverse.h | 2 +-
be/src/vec/functions/function_string.h | 7 +-
be/src/vec/functions/function_uuid.cpp | 1 +
be/src/vec/functions/match.cpp | 2 +-
be/src/vec/jsonb/serialize.cpp | 2 +-
be/src/vec/olap/block_reader.h | 2 +-
be/src/vec/olap/olap_data_convertor.cpp | 23 +-
be/src/vec/olap/olap_data_convertor.h | 4 +-
be/src/vec/olap/vcollect_iterator.cpp | 6 -
be/src/vec/olap/vcollect_iterator.h | 17 +-
be/src/vec/olap/vgeneric_iterators.cpp | 5 +-
be/src/vec/olap/vgeneric_iterators.h | 5 +-
be/src/vec/sink/varrow_flight_result_writer.cpp | 124 +-
be/src/vec/sink/varrow_flight_result_writer.h | 61 +-
be/src/vec/sink/vmysql_result_writer.cpp | 75 +-
be/src/vec/sink/vmysql_result_writer.h | 54 +-
be/src/vec/sink/vrow_distribution.cpp | 3 +
be/src/vec/sink/vrow_distribution.h | 3 +
be/src/vec/sink/writer/vfile_result_writer.cpp | 89 +-
be/src/vec/sink/writer/vfile_result_writer.h | 11 +-
be/src/vec/sink/writer/vtablet_writer.cpp | 9 +-
be/src/vec/spill/spill_stream_manager.cpp | 3 +-
be/test/CMakeLists.txt | 1 -
.../cloud/test_schema_cloud_dictionary_cache.cpp | 178 ++
be/test/io/cache/block_file_cache_test.cpp | 4 +-
be/test/olap/index_builder_test.cpp | 2422 ++++++++++++++++++++
.../segment_v2/inverted_index_writer_test.cpp | 828 +++++++
be/test/olap/tablet_column_object_pool_test.cpp | 166 ++
.../partitioned_hash_join_probe_operator_test.cpp | 1162 ++++++++++
.../partitioned_hash_join_sink_operator_test.cpp | 398 ++++
.../operator/partitioned_hash_join_test_helper.cpp | 243 ++
.../operator/partitioned_hash_join_test_helper.h | 292 +++
be/test/runtime/result_buffer_mgr_test.cpp | 75 +-
be/test/runtime/thread_context_test.cpp | 184 ++
be/test/testutil/column_helper.h | 9 +
be/test/testutil/creators.h | 109 +
be/test/testutil/mock/mock_agg_fn_evaluator.cpp | 14 +
be/test/testutil/mock/mock_agg_fn_evaluator.h | 3 +
be/test/testutil/mock/mock_descriptors.h | 24 +
be/test/testutil/mock/mock_operators.h | 64 +
be/test/testutil/mock/mock_slot_ref.cpp | 7 +
be/test/testutil/mock/mock_slot_ref.h | 2 +
be/test/vec/aggregate_functions/agg_bit_test.cpp | 48 +
.../vec/aggregate_functions/agg_function_test.h | 127 +
.../vec/columns/check_and_get_column_ptr_test.cpp | 143 ++
be/test/vec/columns/column_array_test.cpp | 958 ++++++++
be/test/vec/columns/common_column_test.h | 1293 +++++++----
be/test/vec/core/column_array_test.cpp | 73 -
.../vec/data_types/common_data_type_serder_test.h | 2 +-
be/test/vec/data_types/data_type_ip_test.cpp | 8 +-
.../serde/data_type_serde_agg_state_test.cpp | 439 ++++
.../serde/data_type_serde_arrow_test.cpp | 107 +-
.../serde/data_type_serde_bitmap_test.cpp | 189 ++
.../data_type_serde_fixed_length_object_test.cpp | 227 ++
.../data_types/serde/data_type_serde_hll_test.cpp | 199 ++
.../serde/data_type_serde_mysql_test.cpp | 18 +-
.../serde/data_type_serde_quantile_state_test.cpp | 179 ++
.../vec/data_types/serde/data_type_serde_test.cpp | 4 +-
be/test/vec/exec/column_type_convert_test.cpp | 1117 +++++++++
.../vec/exec/format/orc/orc_file_reader_test.cpp | 170 ++
be/test/vec/exec/parquet/parquet_thrift_test.cpp | 10 +-
be/test/vec/exprs/vexpr_test.cpp | 4 +-
be/test/vec/function/function_test_util.h | 3 +
be/test/vec/olap/jsonb_value_test.cpp | 242 ++
.../vec/sink/arrow_result_block_buffer_test.cpp | 377 +++
be/test/vec/sink/get_result_batch_test.cpp | 148 ++
be/test/vec/sink/result_block_buffer_test.cpp | 319 +++
bin/{profile_fe.sh => flight_record_fe.sh} | 41 +-
bin/profile_fe.sh | 2 +-
cloud/src/common/bvars.cpp | 2 +-
cloud/src/common/bvars.h | 1 +
cloud/src/common/config.h | 2 +
cloud/src/meta-service/meta_service.cpp | 89 +-
cloud/src/meta-service/meta_service.h | 10 +
cloud/src/meta-service/meta_service_schema.cpp | 6 +-
cloud/src/recycler/s3_accessor.cpp | 10 +-
cloud/test/meta_service_test.cpp | 23 +-
common/cpp/s3_rate_limiter.cpp | 2 +-
docker/runtime/be/resource/be_entrypoint.sh | 46 +
docker/runtime/fe/resource/fe_entrypoint.sh | 46 +
.../scripts/create_preinstalled_scripts/run07.hql | 14 +-
.../scripts/create_preinstalled_scripts/run75.hql | 515 +++++
.../orc_table/orc_schema_change/origin_file.orc | Bin 0 -> 2533 bytes
.../parquet_schema_change/origin_file.parquet | Bin 0 -> 3651 bytes
.../main/java/org/apache/doris/common/Config.java | 16 +-
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 64 +-
.../main/java/org/apache/doris/alter/Alter.java | 2 +-
.../java/org/apache/doris/alter/AlterHandler.java | 10 +
.../doris/alter/MaterializedViewHandler.java | 8 +
.../apache/doris/alter/SchemaChangeHandler.java | 7 +
.../java/org/apache/doris/alter/SystemHandler.java | 105 +
.../org/apache/doris/analysis/OutFileClause.java | 6 +
.../java/org/apache/doris/binlog/UpsertRecord.java | 17 +-
.../main/java/org/apache/doris/catalog/Env.java | 2 +-
.../apache/doris/cloud/rpc/MetaServiceClient.java | 21 +-
.../apache/doris/cloud/storage/AzureRemote.java | 15 +-
.../doris/cloud/system/CloudSystemInfoService.java | 11 +
.../transaction/CloudGlobalTransactionMgr.java | 18 +-
.../transaction/DeleteBitmapUpdateLockContext.java | 6 +
.../org/apache/doris/common/profile/Profile.java | 216 +-
.../doris/common/profile/ProfileManager.java | 155 +-
.../org/apache/doris/datasource/CatalogMgr.java | 23 +-
.../org/apache/doris/datasource/FileScanNode.java | 46 +-
.../doris/datasource/hive/HMSExternalTable.java | 2 -
.../datasource/iceberg/IcebergExternalTable.java | 2 -
.../datasource/iceberg/source/IcebergScanNode.java | 12 +-
.../datasource/jdbc/client/JdbcMySQLClient.java | 5 +-
.../datasource/paimon/PaimonExternalTable.java | 2 -
.../datasource/paimon/source/PaimonScanNode.java | 146 +-
.../datasource/paimon/source/PaimonSplit.java | 15 +-
.../property/constants/AzureProperties.java | 17 +-
.../org/apache/doris/fs/obj/AzureObjStorage.java | 15 +-
.../doris/insertoverwrite/InsertOverwriteUtil.java | 7 +-
.../org/apache/doris/load/ExportTaskExecutor.java | 2 +
.../java/org/apache/doris/load/OutfileInfo.java | 6 +
.../org/apache/doris/master/ReportHandler.java | 16 +
.../mysql/privilege/AccessControllerManager.java | 6 +
.../doris/nereids/parser/LogicalPlanBuilder.java | 118 +-
.../expression/rules/SimplifyConflictCompound.java | 32 +-
.../expression/rules/SimplifySelfComparison.java | 7 +-
.../ExtractAndNormalizeWindowExpression.java | 2 +-
.../doris/nereids/stats/ExpressionEstimation.java | 11 +-
.../doris/nereids/stats/StatsCalculator.java | 9 +-
.../functions/executable/NumericArithmetic.java | 7 +-
.../trees/expressions/functions/scalar/Random.java | 61 +-
.../expressions/functions/scalar/RandomBytes.java | 39 +-
.../trees/expressions/functions/scalar/Uuid.java | 36 -
.../expressions/functions/scalar/UuidNumeric.java | 36 -
.../apache/doris/nereids/trees/plans/PlanType.java | 19 +-
.../plans/commands/AlterCatalogCommentCommand.java | 1 +
...and.java => AlterCatalogPropertiesCommand.java} | 29 +-
.../trees/plans/commands/AlterSystemCommand.java | 25 +-
.../commands/ShowColumnHistogramStatsCommand.java | 180 ++
.../trees/plans/commands/ShowDataCommand.java | 694 ++++++
.../plans/commands/ShowStoragePolicyCommand.java | 75 +
.../trees/plans/commands/ShowTableCommand.java | 243 ++
.../plans/commands/UpdateMvByPartitionCommand.java | 7 +
...DropBackendOp.java => AlterLoadErrorUrlOp.java} | 43 +-
.../trees/plans/commands/info/DropBackendOp.java | 4 +
.../trees/plans/commands/info/ModifyBackendOp.java | 12 +
.../info/ModifyFrontendOrBackendHostNameOp.java | 4 +
.../trees/plans/commands/info/TableNameInfo.java | 9 +
.../insert/InsertOverwriteTableCommand.java | 7 +-
.../trees/plans/commands/insert/InsertUtils.java | 3 +-
.../trees/plans/visitor/CommandVisitor.java | 26 +
.../org/apache/doris/planner/ResultFileSink.java | 45 +-
.../java/org/apache/doris/policy/PolicyMgr.java | 74 +-
.../java/org/apache/doris/qe/SessionVariable.java | 25 +-
.../main/java/org/apache/doris/qe/VariableMgr.java | 16 -
.../apache/doris/service/FrontendServiceImpl.java | 35 +-
.../apache/doris/statistics/ColumnStatistic.java | 4 +
.../apache/doris/statistics/OlapAnalysisTask.java | 4 +-
.../doris/statistics/StatisticConstants.java | 4 +
.../doris/statistics/StatisticsRepository.java | 2 +-
.../doris/statistics/util/StatisticsUtil.java | 18 +
.../java/org/apache/doris/system/HeartbeatMgr.java | 9 +
.../org/apache/doris/system/SystemInfoService.java | 69 +
.../doris/tablefunction/MetadataGenerator.java | 26 +-
.../doris/tablefunction/S3TableValuedFunction.java | 17 +-
.../apache/doris/transaction/TransactionState.java | 1 +
.../doris/common/profile/ProfileManagerTest.java | 476 ++--
.../common/profile/ProfilePersistentTest.java | 330 ++-
.../paimon/source/PaimonScanNodeTest.java | 155 ++
.../property/constants/AzurePropertiesTest.java | 55 +
.../rules/expression/ExpressionRewriteTest.java | 2 +-
.../rules/expression/SimplifyRangeTest.java | 24 +-
.../rules/SimplifySelfComparisonTest.java | 2 +-
.../functions/NonfoldableFunctionTest.java | 58 -
.../doris/broker/hdfs/ClientContextManager.java | 10 +-
gensrc/proto/cloud.proto | 14 +
gensrc/proto/olap_file.proto | 6 +
gensrc/thrift/AgentService.thrift | 1 +
gensrc/thrift/FrontendService.thrift | 4 +
gensrc/thrift/PaloInternalService.thrift | 2 +-
gensrc/thrift/PlanNodes.thrift | 3 +
.../compaction/test_config_prune_delete_sign.out | Bin 0 -> 163 bytes
.../data/export_p0/outfile/test_outfile_result.out | Bin 0 -> 225 bytes
.../hive/test_hive_schema_change_orc.out | Bin 0 -> 10902 bytes
.../hive/test_hive_schema_change_parquet.out | Bin 0 -> 11765 bytes
.../kerberos/test_non_catalog_kerberos.out | Bin 0 -> 135 bytes
.../paimon/test_paimon_catalog.out | Bin 795479 -> 795039
bytes
.../paimon/test_paimon_deletion_vector.out | Bin 0 -> 525 bytes
.../hudi/test_hudi_incremental.out | Bin 7551 -> 5687 bytes
.../hudi/test_hudi_schema_evolution.out | Bin 11234 -> 7521 bytes
.../external_table_p2/hudi/test_hudi_snapshot.out | Bin 1044838 -> 696105
bytes
.../hudi/test_hudi_timetravel.out | Bin 3119 -> 2111 bytes
.../test_tablet_state_change_in_publish_phase.out | Bin 0 -> 227 bytes
.../insert_group_commit_with_large_data.out} | Bin 245 -> 221 bytes
.../test_index_change_on_new_column.out | Bin 245 -> 611 bytes
.../data/inverted_index_p0/test_tokenize.out | Bin 2288 -> 2899 bytes
.../test_load_with_transfer_encoding.out | Bin 0 -> 131 bytes
regression-test/data/mtmv_p0/test_base_mtmv.out | Bin 987 -> 1193 bytes
.../array/test_array_array_bool.csv | 19 +
.../nereids_function_p0/array/test_array_bool.csv | 20 +
.../test_alter_catalog_properties_command.out | Bin 0 -> 493 bytes
.../push_down_sum_through_join_one_side.out | Bin 20462 -> 20501 bytes
.../data/nereids_rules_p0/test_nonfoldable.out | Bin 2839 -> 2767 bytes
...t_auto_partition_with_single_replica_insert.csv | 78 +
...t_auto_partition_with_single_replica_insert.out | Bin 0 -> 7985 bytes
regression-test/data/query_p0/sort/heap_sort.csv | 7 +
regression-test/data/query_p0/sort/heap_sort.out | Bin 0 -> 193 bytes
.../tpcds_sf100/noStatsRfPrune/query31.out | Bin 4470 -> 4467 bytes
.../tpcds_sf100/noStatsRfPrune/query47.out | Bin 3262 -> 3450 bytes
.../tpcds_sf100/noStatsRfPrune/query59.out | Bin 2348 -> 2501 bytes
.../tpcds_sf100/noStatsRfPrune/query81.out | Bin 2432 -> 2440 bytes
.../tpcds_sf100/no_stats_shape/query31.out | Bin 4567 -> 4564 bytes
.../tpcds_sf100/no_stats_shape/query47.out | Bin 3620 -> 3536 bytes
.../tpcds_sf100/no_stats_shape/query59.out | Bin 2539 -> 2603 bytes
.../tpcds_sf100/no_stats_shape/query81.out | Bin 2529 -> 2537 bytes
.../shape_check/tpcds_sf100/rf_prune/query30.out | Bin 2501 -> 2484 bytes
.../shape_check/tpcds_sf100/rf_prune/query31.out | Bin 4439 -> 4408 bytes
.../shape_check/tpcds_sf100/rf_prune/query46.out | Bin 2518 -> 2606 bytes
.../shape_check/tpcds_sf100/rf_prune/query58.out | Bin 7205 -> 7152 bytes
.../shape_check/tpcds_sf100/rf_prune/query59.out | Bin 2415 -> 2407 bytes
.../shape_check/tpcds_sf100/rf_prune/query65.out | Bin 2569 -> 2499 bytes
.../shape_check/tpcds_sf100/rf_prune/query79.out | Bin 2059 -> 2061 bytes
.../shape_check/tpcds_sf100/rf_prune/query81.out | Bin 2440 -> 2432 bytes
.../shape_check/tpcds_sf100/rf_prune/query83.out | Bin 5996 -> 6011 bytes
.../data/shape_check/tpcds_sf100/shape/query30.out | Bin 2542 -> 2536 bytes
.../data/shape_check/tpcds_sf100/shape/query31.out | Bin 4536 -> 4505 bytes
.../data/shape_check/tpcds_sf100/shape/query46.out | Bin 2678 -> 2766 bytes
.../data/shape_check/tpcds_sf100/shape/query58.out | Bin 7205 -> 7194 bytes
.../data/shape_check/tpcds_sf100/shape/query59.out | Bin 2517 -> 2509 bytes
.../data/shape_check/tpcds_sf100/shape/query65.out | Bin 2671 -> 2585 bytes
.../data/shape_check/tpcds_sf100/shape/query79.out | Bin 2109 -> 2111 bytes
.../data/shape_check/tpcds_sf100/shape/query81.out | Bin 2537 -> 2529 bytes
.../data/shape_check/tpcds_sf100/shape/query83.out | Bin 5996 -> 6011 bytes
.../data/shape_check/tpcds_sf1000/hint/query65.out | Bin 2906 -> 2820 bytes
.../shape_check/tpcds_sf1000/shape/query30.out | Bin 2525 -> 2517 bytes
.../shape_check/tpcds_sf1000/shape/query31.out | Bin 4536 -> 4505 bytes
.../shape_check/tpcds_sf1000/shape/query58.out | Bin 7194 -> 7194 bytes
.../shape_check/tpcds_sf1000/shape/query59.out | Bin 2517 -> 2509 bytes
.../shape_check/tpcds_sf1000/shape/query65.out | Bin 2671 -> 2585 bytes
.../shape_check/tpcds_sf1000/shape/query81.out | Bin 2537 -> 2529 bytes
.../shape_check/tpcds_sf10t_orc/shape/query2.out | Bin 2152 -> 2074 bytes
.../shape_check/tpcds_sf10t_orc/shape/query31.out | Bin 4280 -> 4277 bytes
.../shape_check/tpcds_sf10t_orc/shape/query47.out | Bin 3620 -> 3536 bytes
.../shape_check/tpcds_sf10t_orc/shape/query74.out | Bin 3769 -> 3737 bytes
.../data/shape_check/tpch_sf1000/rf_prune/q15.out | Bin 1581 -> 1549 bytes
.../data/shape_check/tpch_sf1000/rf_prune/q18.out | Bin 1316 -> 1258 bytes
.../data/shape_check/tpch_sf1000/shape/q15.out | Bin 1581 -> 1549 bytes
.../data/shape_check/tpch_sf1000/shape/q18.out | Bin 1316 -> 1299 bytes
.../partial_update/test_partial_update.out | Bin 1839 -> 2031 bytes
.../partial_update/test_partial_update_s3_load.out | Bin 0 -> 363 bytes
regression-test/data/variant_p0/rqg/rqg6.out | Bin 0 -> 236 bytes
regression-test/data/view_p0/view_p0.out | Bin 3322 -> 3484 bytes
regression-test/framework/pom.xml | 6 +-
.../org/apache/doris/regression/Config.groovy | 2 +-
.../regression/action/FlightRecordAction.groovy | 288 +++
.../org/apache/doris/regression/suite/Suite.groovy | 5 +
.../apache/doris/regression/util/JdbcUtils.groovy | 12 +
.../framework/src/main/groovy/suite.gdsl | 1 +
.../pipeline/external/conf/regression-conf.groovy | 1 +
.../test_master_slave_consistency_auth.groovy | 20 +-
.../ccr_syncer_p1/test_backup_restore.groovy | 9 +-
.../cache/http/test_list_cache_file.groovy | 6 +-
.../warm_up/table/test_warm_up_table.groovy | 11 +-
.../suites/cloud_p0/cache/ttl/alter_ttl_1.groovy | 8 +-
.../suites/cloud_p0/cache/ttl/alter_ttl_2.groovy | 5 +-
.../suites/cloud_p0/cache/ttl/alter_ttl_3.groovy | 6 +-
.../suites/cloud_p0/cache/ttl/alter_ttl_4.groovy | 6 +-
.../cloud_p0/cache/ttl/alter_ttl_max_int64.groovy | 6 +-
.../cloud_p0/cache/ttl/alter_ttl_random.groovy | 6 +-
.../cloud_p0/cache/ttl/alter_ttl_seconds.groovy | 6 +-
.../cache/ttl/create_table_as_select.groovy | 13 +-
.../cloud_p0/cache/ttl/create_table_like.groovy | 7 +-
.../suites/cloud_p0/cache/ttl/test_ttl.groovy | 80 +-
.../cloud_p0/cache/ttl/test_ttl_lru_evict.groovy | 4 +-
.../add_drop_partition.groovy | 18 +-
.../add_drop_partition_by_hdfs.groovy | 16 +-
.../create_table_use_dynamic_partition.groovy | 16 +-
...eate_table_use_dynamic_partition_by_hdfs.groovy | 14 +-
.../create_table_use_partition_policy.groovy | 28 +-
...reate_table_use_partition_policy_by_hdfs.groovy | 28 +-
.../create_table_use_policy.groovy | 20 +-
.../create_table_use_policy_by_hdfs.groovy | 24 +-
.../load_colddata_to_hdfs.groovy | 12 +-
.../modify_replica_use_partition.groovy | 44 +-
.../modify_replica_use_partition_by_hdfs.groovy | 44 +-
.../table_modify_resouce_and_policy.groovy | 24 +-
.../table_modify_resouce_and_policy_by_hdfs.groovy | 24 +-
.../test_config_prune_delete_sign.groovy | 89 +
.../suites/demo_p0/test_flight_record.groovy | 62 +
.../export_p0/outfile/test_outfile_result.groovy | 89 +
.../hive/test_hive_parquet_alter_column.groovy | 5 +
.../hive/test_hive_schema_change.groovy | 4 +-
.../hive/test_hive_schema_change_orc.groovy | 1034 +++++++++
.../hive/test_hive_schema_change_parquet.groovy | 1034 +++++++++
.../jdbc/test_mysql_jdbc_catalog.groovy | 21 +-
.../ctas/test_mysql_all_types_ctas.groovy | 12 +-
.../kerberos/test_non_catalog_kerberos.groovy | 146 ++
.../paimon/test_paimon_catalog.groovy | 14 -
.../paimon/test_paimon_deletion_vector.groovy | 96 +
.../hudi/test_hudi_incremental.groovy | 6 -
.../hudi/test_hudi_schema_evolution.groovy | 11 -
.../hudi/test_hudi_snapshot.groovy | 7 -
.../hudi/test_hudi_timetravel.groovy | 7 -
...est_tablet_state_change_in_publish_phase.groovy | 161 ++
...artial_update_with_delete_col_in_publish.groovy | 2 +-
.../test_skip_calc_between_segments.groovy | 1 -
...nsert_group_commit_into_unique_sync_mode.groovy | 2 +-
.../insert_group_commit_with_large_data.groovy | 50 +-
...mit_insert_into_lineitem_multiple_client.groovy | 8 +-
...mmit_insert_into_lineitem_multiple_table.groovy | 8 +-
...group_commit_insert_into_lineitem_normal.groovy | 5 +-
...ommit_insert_into_lineitem_scheme_change.groovy | 8 +-
.../test_index_change_on_new_column.groovy | 90 +-
.../suites/inverted_index_p0/test_tokenize.groovy | 2 +
.../test_load_with_transfer_encoding.groovy | 119 +
.../suites/mtmv_p0/test_base_mtmv.groovy | 13 +
.../suites/mtmv_p0/test_hive_refresh_mtmv.groovy | 12 +
.../fold_constant_numeric_arithmatic.groovy | 3 +
.../show/test_show_storage_policy_nereids.groovy | 65 +
.../subquery/test_correlated_filter_removed.groovy | 16 +-
.../test_alter_catalog_properties_command.groovy | 55 +
.../push_down_sum_through_join_one_side.groovy | 2 +-
.../normalize_window_nullable_agg_test.groovy | 10 +
...uto_partition_with_single_replica_insert.groovy | 78 +
.../test_partition_storage_policy.groovy | 12 +-
.../test_inject_send_filter_size_fail.groovy | 10 +-
.../limit/test_map_select_with_limit.groovy | 2 +-
.../suites/query_p0/sort/heap_sort.groovy | 46 +
.../test_aggregate_all_functions.groovy | 22 +
.../suites/statistics/test_update_rows_mv.groovy | 2 +
.../partial_update/test_partial_update.groovy | 80 +
.../test_partial_update_s3_load.groovy | 110 +
regression-test/suites/variant_p0/rqg/rqg6.sql | 66 +
regression-test/suites/view_p0/view_p0.groovy | 18 +
.../doris/arrowflight/demo/ArrowBatchReader.java | 23 +
535 files changed, 24480 insertions(+), 4498 deletions(-)
create mode 100644 be/src/cloud/schema_cloud_dictionary_cache.cpp
create mode 100644 be/src/cloud/schema_cloud_dictionary_cache.h
delete mode 100644 be/src/runtime/buffer_control_block.cpp
delete mode 100644 be/src/runtime/buffer_control_block.h
create mode 100644 be/src/runtime/result_block_buffer.cpp
create mode 100644 be/src/runtime/result_block_buffer.h
create mode 100644 be/src/vec/exec/format/orc/orc_file_reader.cpp
create mode 100644 be/src/vec/exec/format/orc/orc_file_reader.h
create mode 100644 be/test/cloud/test_schema_cloud_dictionary_cache.cpp
create mode 100644 be/test/olap/index_builder_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index_writer_test.cpp
create mode 100644 be/test/olap/tablet_column_object_pool_test.cpp
create mode 100644
be/test/pipeline/operator/partitioned_hash_join_probe_operator_test.cpp
create mode 100644
be/test/pipeline/operator/partitioned_hash_join_sink_operator_test.cpp
create mode 100644
be/test/pipeline/operator/partitioned_hash_join_test_helper.cpp
create mode 100644
be/test/pipeline/operator/partitioned_hash_join_test_helper.h
create mode 100644 be/test/runtime/thread_context_test.cpp
create mode 100644 be/test/testutil/creators.h
create mode 100644 be/test/testutil/mock/mock_operators.h
create mode 100644 be/test/vec/aggregate_functions/agg_bit_test.cpp
create mode 100644 be/test/vec/aggregate_functions/agg_function_test.h
create mode 100644 be/test/vec/columns/check_and_get_column_ptr_test.cpp
create mode 100644 be/test/vec/columns/column_array_test.cpp
create mode 100644
be/test/vec/data_types/serde/data_type_serde_agg_state_test.cpp
create mode 100644 be/test/vec/data_types/serde/data_type_serde_bitmap_test.cpp
create mode 100644
be/test/vec/data_types/serde/data_type_serde_fixed_length_object_test.cpp
create mode 100644 be/test/vec/data_types/serde/data_type_serde_hll_test.cpp
create mode 100644
be/test/vec/data_types/serde/data_type_serde_quantile_state_test.cpp
create mode 100644 be/test/vec/exec/column_type_convert_test.cpp
create mode 100644 be/test/vec/exec/format/orc/orc_file_reader_test.cpp
create mode 100644 be/test/vec/olap/jsonb_value_test.cpp
create mode 100644 be/test/vec/sink/arrow_result_block_buffer_test.cpp
create mode 100644 be/test/vec/sink/get_result_batch_test.cpp
create mode 100644 be/test/vec/sink/result_block_buffer_test.cpp
copy bin/{profile_fe.sh => flight_record_fe.sh} (61%)
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/create_preinstalled_scripts/run75.hql
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/orc_table/orc_schema_change/origin_file.orc
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/parquet_table/parquet_schema_change/origin_file.parquet
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/{AlterCatalogCommentCommand.java
=> AlterCatalogPropertiesCommand.java} (61%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowColumnHistogramStatsCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowDataCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowStoragePolicyCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowTableCommand.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/{DropBackendOp.java
=> AlterLoadErrorUrlOp.java} (54%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/paimon/source/PaimonScanNodeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/constants/AzurePropertiesTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/NonfoldableFunctionTest.java
create mode 100644
regression-test/data/compaction/test_config_prune_delete_sign.out
create mode 100644
regression-test/data/export_p0/outfile/test_outfile_result.out
create mode 100644
regression-test/data/external_table_p0/hive/test_hive_schema_change_orc.out
create mode 100644
regression-test/data/external_table_p0/hive/test_hive_schema_change_parquet.out
create mode 100644
regression-test/data/external_table_p0/kerberos/test_non_catalog_kerberos.out
create mode 100644
regression-test/data/external_table_p0/paimon/test_paimon_deletion_vector.out
create mode 100644
regression-test/data/fault_injection_p0/cloud/test_tablet_state_change_in_publish_phase.out
copy
regression-test/data/{inverted_index_p0/index_change/test_index_change_on_new_column.out
=> insert_p0/insert_group_commit_with_large_data.out} (51%)
create mode 100644
regression-test/data/load_p0/stream_load/test_load_with_transfer_encoding.out
create mode 100644
regression-test/data/nereids_function_p0/array/test_array_array_bool.csv
create mode 100644
regression-test/data/nereids_function_p0/array/test_array_bool.csv
create mode 100644
regression-test/data/nereids_p0/test_alter_catalog_properties_command.out
create mode 100644
regression-test/data/partition_p0/auto_partition/test_auto_partition_with_single_replica_insert.csv
create mode 100644
regression-test/data/partition_p0/auto_partition/test_auto_partition_with_single_replica_insert.out
create mode 100644 regression-test/data/query_p0/sort/heap_sort.csv
create mode 100644 regression-test/data/query_p0/sort/heap_sort.out
create mode 100644
regression-test/data/unique_with_mow_p0/partial_update/test_partial_update_s3_load.out
create mode 100644 regression-test/data/variant_p0/rqg/rqg6.out
create mode 100644
regression-test/framework/src/main/groovy/org/apache/doris/regression/action/FlightRecordAction.groovy
create mode 100644
regression-test/suites/compaction/test_config_prune_delete_sign.groovy
create mode 100644 regression-test/suites/demo_p0/test_flight_record.groovy
create mode 100644
regression-test/suites/export_p0/outfile/test_outfile_result.groovy
create mode 100644
regression-test/suites/external_table_p0/hive/test_hive_schema_change_orc.groovy
create mode 100644
regression-test/suites/external_table_p0/hive/test_hive_schema_change_parquet.groovy
create mode 100644
regression-test/suites/external_table_p0/kerberos/test_non_catalog_kerberos.groovy
create mode 100644
regression-test/suites/external_table_p0/paimon/test_paimon_deletion_vector.groovy
create mode 100644
regression-test/suites/fault_injection_p0/cloud/test_tablet_state_change_in_publish_phase.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_load_with_transfer_encoding.groovy
create mode 100644
regression-test/suites/nereids_p0/show/test_show_storage_policy_nereids.groovy
create mode 100644
regression-test/suites/nereids_p0/test_alter_catalog_properties_command.groovy
create mode 100644
regression-test/suites/partition_p0/auto_partition/test_auto_partition_with_single_replica_insert.groovy
create mode 100644 regression-test/suites/query_p0/sort/heap_sort.groovy
create mode 100644
regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_s3_load.groovy
create mode 100644 regression-test/suites/variant_p0/rqg/rqg6.sql
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
