This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch auto-pick-62141-branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
discard 0dea8bf3370 [enhance](nereids) improve masking of user's password for
ALTER USER and CREATE USER commands in audit logs (#62141)
add 8881ac9b7c3 branch-4.1: [fix](variant) Fix variant flat-leaf root read
plan #63086 #63104 (#63098)
add 170d6db4405 branch-4.1: [refactor](fe) Add fe-foundation module with
zero-dependency JDK-onlyutilities (#62638)
add 31ed979e9b3 branch-4.1: [fix](audit) Mark internal query failures as
ERR in audit log (#62996)
add 7792740d354 branch-4.1: [cloud](fe) RestoreJob cannot deserialize
Tablet when upgrade #62673 (#63099)
add 4e56d3f8e28 branch-4.1: [chore](expr) remove useless if in
`is_acting_on_a_slot` #63095 (#63115)
add 043735efe3b branch-4.1: [improvement](recycler) Avoid single-point
read/write during sequentially reading key #62476 (#63123)
add 31314733ac4 branch-4.1: [fix](timestamptz) Preserve correct DST fold
branch to go cross the transition point #63034 (#63091)
add 83d9e7009f5 [feature](be) Add adaptive batch size for scan path
(#62835) (#63005)
add 0f8f8fce29e branch-4.1: [fix](filecache) avoid SIGSEGV in background
LRU update when clear cache #60533 (#61445)
add 2a5147b1262 branch-4.1：[improvement](executor) unify current query
runtime statistics and expose task progress (#60567) (#63130)
add 55d255f3ddf branch-4.1: [fix](mv) Align extra-join elimination safety
check #62527 (#63139)
add 555a2ea657f branch-4.1: [fix](backup) reject upload snapshots on
broken storage path #61251 (#61436)
add d0888cbd045 branch-4.1: [fix](fe) Return unknown stats for system
tables #62913 (#63010)
add e79c08eda21 branch-4.1: [fix](be) Correct Arrow UTF8/String size limit
#63137 (#63148)
add 4991f2d6e90 branch-4.1: [fix](fe) Fix remote Flight SQL result
receiver initialization #63136 (#63155)
add 5a742877a72 branch-4.1: [fix](filecache) avoid BE crash when finalize
misses local cache writer #62389 (#63179)
add f708be5c7d8 branch-4.1: [fix](decimal) Fix incorrect decimal cast
results for scientific-notation strings #63119 (#63184)
add 6c774aa1535 branch-4.1: [fix](load) rebuild broker load storage
properties after Gson replay #63094 (#63177)
add c94e8c1442d branch-4.1: [fix](insert) Avoid formatting generated
insert errors #62982 (#63158)
add e01d7c87679 branch-4.1: [fix](memtable) use CPU metrics delta for CPU
pressure detection in adaptive flush controller #62744 (#62943)
add 97d04001d7e branch-4.1: [fix](streaming-job) start counting task max
interval after the first record is received #63141 (#63163)
add c180e7cca69 branch-4.1: [fix](memory-tracker) Avoid nested task attach
in cloud snapshot manager #63189 (#63235)
add 89da1665cc2 branch-4.1: [Fix](ttz) Fix TIMESTAMPTZ elapsed-time
semantics to use UTC #63161 (#63248)
add e7525459f8f branch-4.1: [fix](statistics) Skip statistics cache for
system dbs #63089 (#63198)
add f27a1e5b9eb [fix](scan) Fix adaptive load batch sizing (#63245)
add 3125bc3adaa [fix](be) Fix runtime filter crash with shared hash table
(#63256)
add 4a375e28ec1 branch-4.1: [fix](fe) Fix deep nested complex type subtype
validation bypass #63208 (#63222)
add 0731a7683d2 4.1.1-rc01 (#63337)
add b10073ad9ca [branch-4.1] Fix meta tool build (#63371)
add e4d768ddd06 branch-4.1: [fix](streaming-job) restore split-bound Java
types when reading FE-persisted CDC offset #63219 (#63272)
add 31a6f606632 branch-4.1: [Improve](variant) Keep first duplicate
Variant JSON path #63082 (#63156)
add 12645bda20a branch-4.1: [fix](compaction) Fix incorrect memory
availability check in RowSourceBuffer during vertical compaction #63152 (#63232)
add b78b5a0bff9 branch-4.1: [fix](nereids) Run CheckCast on INSERT VALUES
to reject illegal casts #62905 (#63204)
add 44c6c26186b branch-4.1: [feature](statistics) Skip collecting stats
for long string columns #62686 (#63303)
add 71e86457883 [4.1](column) remove IDataType get_default (#62582)
(#63308)
add 7e7545a86d9 [4.1](code) remove dead code across core types and
utilities (#63307)
add a47f436f025 [pick](branch-4.1)pick 62947 63055 63070 to 4.1 (#63297)
add e2192e2b7d6 branch-4.1: [fix](thrift) Reserve frontend service field
ids #63239 (#63335)
add 7383d74a429 [4.1](agg,array) support TIMESTAMPTZ in multiple aggregate
and array … (#63293)
add e381f9d40d3 branch-4.1: [fix](be) Fix json contains duplicate array
candidates #63301 (#63339)
add 406129168ea branch-4.1: [fix](be) Reject super wildcard path in json
keys #63300 (#63369)
add 758f8c6143e branch-4.1: [fix](be) Move partitioned agg shared cleanup
to shared state #63253 (#63287)
add 4d2eeda3797 branch-4.1: [fix](recycler) Recycler/Ms http api result
msg should set ok #63051 (#63275)
add 7df5214b255 branch-4.1: [fix](regression) fix stale expected output
for one_level_nestedtypes_with_s3data #62488 (#63273)
add 0a37a0e872b branch-4.1: [opt](nereids)pass ConnectContext to
canUseNereidsDistributePlanner method instead of call ConnectContext.get()
#60529 (#63202)
add b620c72f01b branch-4.1: [improve](streaming-job) add per-job lag
metric to streaming insert jobs #63194 (#63271)
add 8ee6c80e47f branch-4.1: [fix](streamingjob) Persist cdc_stream TVF
offset across FE checkpoint #62902 (#63270)
add d418004c86b branch-4.1:[fix](ldap) Improve LDAP authentication
resiliency and diagnostics (#61673) (#63288)
add a7af9f66ca1 branch-4.1: [fix](Expr) add SerDe for ColumnRefExpr and
Expr SerDe unit test #62900 (#63127)
add 9389a6043b2 branch-4.1: [fix](fe) Fix alias function with cast
outermost expr and reject illegal expressions #63254 (#63349)
add 502862e0066 branch-4.1: [fix](fe) Reject lone UTF-16 surrogates in
JSONB literals (RFC 8259 §8.2) #63255 (#63347)
add 1a93a62bc96 branch-4.1: [fix](parquet) Fix wrong encoding for parquet
page v2 #63305 (#63373)
add 53829fc1e80 branch-4.1: [fix](streaming-job) recompute derived fields
after replay and ALTER #62936 (#63261)
add a6dbf94b13b branch-4.1: [fix](be) Preserve collect aggregate limit
during merge #63361 (#63383)
add 631b91ca0ad branch-4.1: fix: block type reset after dict filter #63168
(#63419)
add f692ae615df branch-4.1: [fix](fe) fix host not match if start fe in
metadata_failure_recovery (#62748) (#63362)
add 443bcbacf2c branch-4.1: [fix](job-manager) cancelTaskById should not
be blocked by unrelated streaming jobs #62940 (#63262)
add 5b733b41cf0 branch-4.1: [fix](testcase) Fix wrong test case #63354
(#63375)
add 78a7453725f branch-4.1: [fix](case) fix regression:test_predefine_ddl
#60133 (#63203)
add 0bdd0dc9929 [branch-4.1](inverted-index) replace void* query_value
with typed param interface (#62960) (#63157)
add 20893b0955a [enhance](nereids) improve masking of user's password for
ALTER USER and CREATE USER commands in audit logs (#62141)
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 (0dea8bf3370)
\
N -- N -- N refs/heads/auto-pick-62141-branch-4.1 (20893b0955a)
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:
be/CMakeLists.txt | 5 +-
be/src/cloud/cloud_snapshot_mgr.cpp | 6 +-
be/src/cloud/cloud_tablet.cpp | 7 +
be/src/common/config.cpp | 3 +
be/src/common/config.h | 7 +
be/src/common/metrics/system_metrics.cpp | 25 +
be/src/common/metrics/system_metrics.h | 11 +
be/src/common/thread_safety_annotations.h | 171 +++++
be/src/core/binary_cast.hpp | 34 -
be/src/core/block/block.cpp | 33 -
be/src/core/block/block.h | 23 +-
be/src/core/call_on_type_index.h | 2 -
be/src/core/column/column_variant.cpp | 73 +-
be/src/core/column/column_variant.h | 6 -
be/src/core/data_type/data_type.cpp | 4 +-
be/src/core/data_type/data_type.h | 5 -
be/src/core/data_type/data_type_array.cpp | 6 -
be/src/core/data_type/data_type_array.h | 1 -
be/src/core/data_type/data_type_bitmap.h | 4 -
be/src/core/data_type/data_type_decimal.cpp | 5 -
be/src/core/data_type/data_type_decimal.h | 2 -
.../core/data_type/data_type_fixed_length_object.h | 2 -
be/src/core/data_type/data_type_hll.h | 4 -
be/src/core/data_type/data_type_jsonb.cpp | 11 -
be/src/core/data_type/data_type_jsonb.h | 2 -
be/src/core/data_type/data_type_map.cpp | 10 -
be/src/core/data_type/data_type_map.h | 1 -
be/src/core/data_type/data_type_nothing.h | 6 -
be/src/core/data_type/data_type_nullable.cpp | 4 -
be/src/core/data_type/data_type_nullable.h | 2 -
be/src/core/data_type/data_type_number_base.cpp | 5 -
be/src/core/data_type/data_type_number_base.h | 2 -
be/src/core/data_type/data_type_quantilestate.h | 4 -
be/src/core/data_type/data_type_string.cpp | 4 -
be/src/core/data_type/data_type_string.h | 2 -
be/src/core/data_type/data_type_struct.cpp | 9 -
be/src/core/data_type/data_type_struct.h | 2 -
be/src/core/data_type/data_type_varbinary.cpp | 4 -
be/src/core/data_type/data_type_varbinary.h | 2 -
be/src/core/data_type/data_type_variant.h | 1 -
be/src/core/data_type/nested_utils.cpp | 5 -
be/src/core/data_type/nested_utils.h | 6 -
be/src/core/data_type/number_traits.h | 84 ---
.../core/data_type_serde/data_type_array_serde.h | 1 -
.../data_type_serde/data_type_variant_serde.cpp | 6 +-
be/src/core/field.cpp | 12 +-
be/src/core/string_ref.cpp | 13 -
be/src/core/string_ref.h | 2 -
be/src/core/value/map_value.h | 2 -
be/src/core/value/struct_value.h | 2 -
be/src/core/value/timestamptz_value.cpp | 32 +
be/src/core/value/timestamptz_value.h | 13 +-
be/src/exec/common/variant_util.cpp | 213 ++----
be/src/exec/operator/analytic_sink_operator.cpp | 4 +-
be/src/exec/operator/analytic_source_operator.cpp | 9 +-
be/src/exec/operator/data_queue.cpp | 233 ++++---
be/src/exec/operator/data_queue.h | 111 +--
be/src/exec/operator/exchange_sink_operator.cpp | 3 +-
be/src/exec/operator/exchange_sink_operator.h | 6 +-
be/src/exec/operator/hashjoin_build_sink.cpp | 13 +-
be/src/exec/operator/hashjoin_build_sink.h | 5 +-
be/src/exec/operator/mock_scan_operator.h | 27 +-
be/src/exec/operator/multi_cast_data_streamer.cpp | 19 +-
be/src/exec/operator/multi_cast_data_streamer.h | 19 +-
be/src/exec/operator/olap_scan_operator.cpp | 5 +
be/src/exec/operator/olap_scan_operator.h | 3 +
be/src/exec/operator/operator.cpp | 18 +-
be/src/exec/operator/operator.h | 26 +
.../exec/operator/partition_sort_sink_operator.cpp | 10 +-
.../operator/partition_sort_source_operator.cpp | 9 +-
.../partitioned_aggregation_source_operator.cpp | 7 -
be/src/exec/operator/scan_operator.cpp | 4 +-
be/src/exec/operator/scan_operator.h | 10 +-
be/src/exec/operator/schema_scan_operator.cpp | 8 +-
be/src/exec/operator/schema_scan_operator.h | 8 +-
be/src/exec/pipeline/dependency.cpp | 5 +
be/src/exec/pipeline/dependency.h | 25 +-
be/src/exec/pipeline/pipeline_fragment_context.cpp | 4 +
be/src/exec/pipeline/pipeline_fragment_context.h | 5 +-
.../runtime_filter_producer_helper.cpp | 29 +-
be/src/exec/scan/file_scanner.cpp | 131 +++-
be/src/exec/scan/file_scanner.h | 19 +-
be/src/exec/scan/olap_scanner.cpp | 10 +
be/src/exec/scan/scanner.cpp | 7 +-
.../exprs/aggregate/aggregate_function_collect.h | 9 +-
.../aggregate_function_group_array_set_op_impl.h | 88 +--
.../aggregate/aggregate_function_histogram.cpp | 2 +-
.../exprs/aggregate/aggregate_function_map_v2.cpp | 1 +
.../aggregate/aggregate_function_min_max_by.cpp | 66 +-
.../aggregate/aggregate_function_min_max_by.h | 151 ++--
.../aggregate_function_sequence_match.cpp | 3 +
.../aggregate/aggregate_function_sequence_match.h | 7 +-
.../aggregate/aggregate_function_window_funnel.cpp | 7 +-
.../aggregate/aggregate_function_window_funnel.h | 34 +-
.../aggregate_function_window_funnel_v2.cpp | 7 +-
.../aggregate_function_window_funnel_v2.h | 27 +-
.../array/function_array_enumerate_uniq.cpp | 1 +
be/src/exprs/function/array/function_array_index.h | 115 +---
.../exprs/function/array/function_arrays_overlap.h | 9 +-
.../function_date_or_datetime_computation.cpp | 6 +-
.../function_date_or_datetime_computation.h | 16 +-
.../function/function_datetime_floor_ceil.cpp | 19 +-
be/src/exprs/function/function_ip.h | 12 +-
be/src/exprs/function/function_jsonb.cpp | 4 +-
be/src/exprs/function/function_multi_match.cpp | 7 +-
.../function/function_other_types_to_date.cpp | 8 +-
be/src/exprs/function/functions_comparison.h | 8 +-
be/src/exprs/function/in.h | 7 +-
be/src/exprs/function/match.cpp | 7 +-
be/src/exprs/vexpr.cpp | 3 -
be/src/format/arrow/arrow_row_batch.h | 2 +-
be/src/format/csv/csv_reader.cpp | 22 +-
be/src/format/csv/csv_reader.h | 9 +-
be/src/format/generic_reader.h | 5 +
be/src/format/json/new_json_reader.cpp | 25 +-
be/src/format/json/new_json_reader.h | 16 +-
be/src/format/orc/vorc_reader.cpp | 29 +-
be/src/format/orc/vorc_reader.h | 9 +-
be/src/format/parquet/vparquet_group_reader.cpp | 4 +-
be/src/format/parquet/vparquet_reader.cpp | 11 +-
be/src/format/parquet/vparquet_reader.h | 4 +
be/src/format/text/text_reader.cpp | 5 +-
be/src/format/text/text_reader.h | 3 +-
be/src/io/cache/block_file_cache.cpp | 26 +-
be/src/io/cache/file_block.h | 2 +-
be/src/io/cache/fs_file_cache_storage.cpp | 8 +-
be/src/io/fs/local_file_system.cpp | 14 +
be/src/io/fs/local_file_system.h | 2 +
be/src/runtime/query_context.cpp | 12 +
be/src/runtime/query_context.h | 6 +
be/src/runtime/runtime_state.h | 30 +-
be/src/runtime/snapshot_loader.cpp | 28 +
be/src/runtime/snapshot_loader.h | 2 +
be/src/runtime/workload_management/io_context.h | 4 +
.../workload_management/query_task_controller.cpp | 18 +
.../workload_management/query_task_controller.h | 10 +
.../workload_management/resource_context.cpp | 8 +
be/src/service/internal_service.cpp | 10 +-
be/src/storage/adaptive_thread_pool_controller.cpp | 35 +-
be/src/storage/adaptive_thread_pool_controller.h | 9 +-
be/src/storage/compaction/compaction.cpp | 12 +-
be/src/storage/field.h | 23 +-
.../index/inverted/inverted_index_iterator.cpp | 2 +-
.../index/inverted/inverted_index_iterator.h | 5 +-
.../index/inverted/inverted_index_reader.cpp | 141 +++-
.../storage/index/inverted/inverted_index_reader.h | 123 +---
be/src/storage/iterator/block_reader.cpp | 37 +-
be/src/storage/iterator/block_reader.h | 10 +
be/src/storage/iterator/vcollect_iterator.cpp | 63 +-
be/src/storage/iterator/vcollect_iterator.h | 11 +
.../storage/iterator/vertical_merge_iterator.cpp | 10 +-
be/src/storage/iterators.h | 2 +
be/src/storage/key_coder.h | 58 ++
be/src/storage/olap_common.h | 3 +
be/src/storage/partial_update_info.cpp | 6 +-
be/src/storage/predicate/comparison_predicate.h | 7 +-
be/src/storage/predicate/in_list_predicate.h | 14 +-
be/src/storage/row_cursor.cpp | 84 +--
be/src/storage/rowset/beta_rowset_reader.cpp | 1 +
be/src/storage/rowset/beta_rowset_writer.cpp | 131 ++--
be/src/storage/rowset/rowset_reader_context.h | 3 +
.../segment/adaptive_block_size_predictor.cpp | 84 +++
.../segment/adaptive_block_size_predictor.h | 108 +++
be/src/storage/segment/segment.cpp | 17 +
be/src/storage/segment/segment.h | 15 +-
be/src/storage/segment/segment_iterator.cpp | 77 ++-
be/src/storage/segment/segment_iterator.h | 10 +
.../segment/variant/variant_column_reader.cpp | 40 +-
be/src/storage/snapshot/snapshot_manager.cpp | 4 +-
be/src/storage/tablet/base_tablet.cpp | 220 +++++-
be/src/storage/tablet/base_tablet.h | 4 +
be/src/storage/tablet/tablet_reader.h | 13 +-
be/src/storage/types.cpp | 2 -
be/src/storage/types.h | 172 +----
be/src/tools/CMakeLists.txt | 2 +
be/src/tools/meta_tool.cpp | 21 +-
be/src/util/block_budget.h | 92 +++
be/src/util/cgroup_util.cpp | 1 +
be/src/util/json/json_parser.cpp | 54 +-
be/src/util/json/json_parser.h | 5 +
be/src/util/jsonb_document.h | 48 +-
be/src/util/string_parser.cpp | 49 +-
be/test/common/block_budget_test.cpp | 125 ++++
be/test/core/block/block_test.cpp | 2 -
be/test/core/column/column_variant_test.cpp | 218 ++----
be/test/core/data_type/common_data_type_test.h | 1 -
be/test/core/data_type/data_type_array_test.cpp | 6 +-
.../core/data_type/data_type_datetime_v2_test.cpp | 17 -
be/test/core/data_type/data_type_decimal_test.cpp | 14 -
.../data_type/data_type_insert_default_test.cpp | 348 ++++++++++
be/test/core/data_type/data_type_jsonb_test.cpp | 6 -
be/test/core/data_type/data_type_number_test.cpp | 7 -
be/test/core/data_type/data_type_string_test.cpp | 2 -
.../core/data_type/data_type_varbinary_test.cpp | 7 -
.../core/data_type_serde/data_type_serde_test.cpp | 45 --
be/test/exec/common/schema_util_test.cpp | 42 +-
be/test/exec/pipeline/data_queue_test.cpp | 309 ++++++++-
be/test/exec/pipeline/local_exchanger_test.cpp | 18 +-
.../pipeline/multi_cast_data_streamer_test.cpp | 17 +-
.../pipeline/partitioned_agg_shared_state_test.cpp | 4 +-
be/test/exec/pipeline/pipeline_test.cpp | 125 ++++
.../column_array_update_crc32c_batch_37.out | 4 +-
...n_array_update_crc32c_batch_37.out_with_nullmap | 4 +-
.../column_array_update_crc32c_single_37.out | 2 +-
..._array_update_crc32c_single_37.out_with_nullmap | 2 +-
be/test/exprs/aggregate/agg_collect_test.cpp | 72 +-
be/test/exprs/function/cast/cast_to_decimal.cpp | 33 +-
...ion_comparison_evaluate_inverted_index_test.cpp | 4 +-
be/test/exprs/function/function_ip_test.cpp | 4 +-
be/test/exprs/function/function_jsonb_test.cpp | 74 +-
be/test/format/csv/csv_reader_test.cpp | 88 +++
be/test/format/json/json_reader_test.cpp | 90 +++
be/test/format/orc/orc_convert_dict_test.cpp | 10 +-
be/test/format/orc/orc_reader_fill_data_test.cpp | 12 +-
be/test/format/orc/orc_reader_init_column_test.cpp | 6 +-
be/test/format/orc/orc_reader_test.cpp | 2 +-
be/test/format/parquet/parquet_thrift_test.cpp | 31 +
be/test/io/cache/block_file_cache_test.cpp | 17 +
be/test/io/cache/need_update_lru_blocks_test.cpp | 39 ++
be/test/io/fs/local_file_system_test.cpp | 9 +
.../runtime/runtime_state_block_budget_test.cpp | 167 +++++
be/test/runtime/snapshot_loader_test.cpp | 47 ++
.../adaptive_thread_pool_controller_test.cpp | 69 ++
.../storage/compaction/segcompaction_mow_test.cpp | 116 ++++
.../compaction/vertical_compaction_test.cpp | 401 +++++++++++
.../compaction/util/index_compaction_utils.cpp | 7 +-
.../iterator/block_reader_agg_flush_test.cpp | 239 +++++++
.../iterator/block_reader_batch_max_rows_test.cpp | 144 ++++
.../vcollect_iterator_collected_enough_test.cpp | 383 +++++++++++
be/test/storage/key_coder_test.cpp | 352 ++++++++++
.../segment/adaptive_block_size_predictor_test.cpp | 357 ++++++++++
.../storage/segment/index_reader_helper_test.cpp | 4 +-
.../segment/inverted_index_iterator_test.cpp | 4 +-
.../storage/segment/inverted_index_reader_test.cpp | 757 +++++++++++++++++++--
.../storage/segment/inverted_index_writer_test.cpp | 22 +-
be/test/storage/segment/mock/mock_segment.h | 4 +
.../segment/segment_column_raw_data_bytes_test.cpp | 66 ++
.../segment/variant_column_writer_reader_test.cpp | 24 +-
be/test/storage/segment/variant_util_test.cpp | 218 +++++-
be/test/storage/storage_types_test.cpp | 30 -
be/test/storage/test_data/tablet_meta_test.hdr | Bin 0 -> 280 bytes
be/test/testutil/mock/mock_runtime_state.h | 13 +
be/test/util/jsonb_contains_test.cpp | 64 ++
be/test/util/profile_spec_test.cpp | 79 ++-
be/test/util/test_data/stat_cpu_busy_after | 1 +
be/test/util/test_data/stat_cpu_busy_before | 1 +
be/test/util/test_data/stat_cpu_iowait_after | 1 +
be/test/util/test_data/stat_cpu_recovery_after | 1 +
be/test/util/test_data/stat_cpu_regressed_after | 1 +
cloud/src/common/config.h | 2 +-
cloud/src/common/http_helper.cpp | 8 +-
cloud/src/meta-service/meta_service_http.cpp | 10 +-
cloud/src/meta-service/meta_service_http.h | 6 +-
cloud/src/recycler/recycler.cpp | 446 ++++++++----
cloud/src/recycler/recycler.h | 3 +-
cloud/test/meta_service_http_test.cpp | 6 +-
docker/runtime/doris-compose/cluster.py | 6 +
docker/runtime/doris-compose/command.py | 45 +-
docker/runtime/doris-compose/resource/fdb.conf | 4 +-
docker/runtime/doris-compose/resource/init_fdb.sh | 19 +
docker/runtime/doris-compose/resource/init_fe.sh | 29 +-
.../apache/doris/hudi/HadoopHudiJniScanner.java | 2 +-
.../org/apache/doris/common/jni/JniScanner.java | 4 +
.../apache/doris/common/jni/JniScannerTest.java | 42 ++
fe/fe-common/pom.xml | 4 +
.../main/java/org/apache/doris/common/Config.java | 17 +
.../java/org/apache/doris/common/LdapConfig.java | 31 +-
fe/fe-core/pom.xml | 4 +
.../org/apache/doris/analysis/ArrayLiteral.java | 2 +-
.../org/apache/doris/analysis/BoolLiteral.java | 2 +-
.../java/org/apache/doris/analysis/BrokerDesc.java | 2 +-
.../java/org/apache/doris/analysis/CastExpr.java | 2 +-
.../org/apache/doris/analysis/ColumnRefExpr.java | 5 +
.../org/apache/doris/analysis/DateLiteral.java | 2 +-
.../org/apache/doris/analysis/DecimalLiteral.java | 2 +-
.../main/java/org/apache/doris/analysis/Expr.java | 3 +-
.../org/apache/doris/analysis/FloatLiteral.java | 2 +-
.../org/apache/doris/analysis/IPv4Literal.java | 2 +-
.../org/apache/doris/analysis/IPv6Literal.java | 2 +-
.../org/apache/doris/analysis/JsonLiteral.java | 41 +-
.../org/apache/doris/analysis/LiteralExpr.java | 2 +-
.../java/org/apache/doris/analysis/MapLiteral.java | 2 +-
.../java/org/apache/doris/analysis/MaxLiteral.java | 2 +-
.../org/apache/doris/analysis/NullLiteral.java | 2 +-
.../org/apache/doris/analysis/PlaceHolderExpr.java | 2 +-
.../org/apache/doris/analysis/StorageDesc.java | 24 +-
.../org/apache/doris/analysis/StringLiteral.java | 2 +-
.../org/apache/doris/analysis/StructLiteral.java | 2 +-
.../apache/doris/analysis/VarBinaryLiteral.java | 2 +-
.../doris/catalog/BuiltinScalarFunctions.java | 2 +
.../main/java/org/apache/doris/catalog/Env.java | 51 ++
.../java/org/apache/doris/catalog/EnvFactory.java | 4 +-
.../common/proc/CurrentQueryFragmentProcNode.java | 89 ---
.../common/proc/CurrentQueryInfoProvider.java | 200 ------
.../doris/common/proc/CurrentQuerySqlProcDir.java | 70 --
.../proc/CurrentQueryStatementsProcNode.java | 71 --
.../common/proc/CurrentQueryStatisticsProcDir.java | 80 ++-
.../org/apache/doris/common/proc/ProcService.java | 2 +-
.../doris/common/profile/RuntimeProfile.java | 5 -
.../org/apache/doris/common/util/LocationPath.java | 2 +-
.../org/apache/doris/common/util/PrintableMap.java | 2 +-
.../apache/doris/datasource/InternalCatalog.java | 2 +-
.../doris/datasource/hive/HMSTransaction.java | 2 +-
.../datasource/property/ConnectionProperties.java | 4 +-
.../metastore/AWSGlueMetaStoreBaseProperties.java | 6 +-
.../metastore/AbstractIcebergProperties.java | 2 +-
.../metastore/AbstractPaimonProperties.java | 2 +-
.../metastore/AliyunDLFBaseProperties.java | 8 +-
.../property/metastore/HMSBaseProperties.java | 6 +-
.../metastore/HiveGlueMetaStoreProperties.java | 2 +-
.../property/metastore/HiveHMSProperties.java | 2 +-
.../metastore/IcebergHMSMetaStoreProperties.java | 2 +-
.../metastore/IcebergJdbcMetaStoreProperties.java | 2 +-
.../property/metastore/IcebergRestProperties.java | 4 +-
.../metastore/PaimonHMSMetaStoreProperties.java | 2 +-
.../metastore/PaimonJdbcMetaStoreProperties.java | 2 +-
.../metastore/PaimonRestMetaStoreProperties.java | 4 +-
.../storage/AbstractS3CompatibleProperties.java | 4 +-
.../property/storage/AzureProperties.java | 4 +-
.../property/storage/AzurePropertyUtils.java | 2 +-
.../property/storage/BrokerProperties.java | 2 +-
.../datasource/property/storage/COSProperties.java | 2 +-
.../datasource/property/storage/GCSProperties.java | 2 +-
.../property/storage/HdfsProperties.java | 2 +-
.../property/storage/HdfsPropertiesUtils.java | 2 +-
.../property/storage/MinioProperties.java | 2 +-
.../datasource/property/storage/OBSProperties.java | 2 +-
.../property/storage/OSSHdfsProperties.java | 2 +-
.../datasource/property/storage/OSSProperties.java | 4 +-
.../property/storage/OzoneProperties.java | 2 +-
.../datasource/property/storage/S3Properties.java | 4 +-
.../property/storage/S3PropertyUtils.java | 2 +-
.../property/storage/StorageProperties.java | 4 +-
.../httpv2/rest/manager/QueryProfileAction.java | 10 +-
.../insert/streaming/StreamingInsertJob.java | 38 +-
.../org/apache/doris/job/manager/JobManager.java | 6 +-
.../offset/jdbc/JdbcTvfSourceOffsetProvider.java | 71 +-
.../java/org/apache/doris/metric/MetricRepo.java | 14 +
.../mysql/authenticate/AuthenticatorManager.java | 16 +
.../mysql/authenticate/ldap/LdapAuthenticator.java | 38 +-
.../doris/mysql/authenticate/ldap/LdapClient.java | 69 +-
.../doris/mysql/authenticate/ldap/LdapManager.java | 52 +-
.../doris/mysql/privilege/UserPropertyMgr.java | 5 +
.../org/apache/doris/nereids/NereidsPlanner.java | 2 +-
.../org/apache/doris/nereids/StatementContext.java | 2 +-
.../jobs/joinorder/hypergraph/HyperGraph.java | 8 +-
.../jobs/joinorder/hypergraph/edge/FilterEdge.java | 11 +-
.../rules/exploration/mv/HyperGraphComparator.java | 51 +-
.../expressions/functions/agg/SequenceCount.java | 3 +
.../functions/agg/SequenceFunction.java | 2 +-
.../expressions/functions/agg/SequenceMatch.java | 3 +
.../expressions/functions/agg/TopNWeighted.java | 8 +
.../expressions/functions/agg/WindowFunnel.java | 15 +-
.../expressions/functions/agg/WindowFunnelV2.java | 15 +-
.../expressions/functions/scalar/DateDiff.java | 3 +
.../expressions/functions/scalar/DaysDiff.java | 2 +
.../expressions/functions/scalar/HoursDiff.java | 3 +
.../functions/scalar/MicroSecondsDiff.java | 3 +
.../functions/scalar/MilliSecondsDiff.java | 3 +
.../expressions/functions/scalar/MinutesDiff.java | 3 +
.../expressions/functions/scalar/MonthsDiff.java | 7 +-
.../expressions/functions/scalar/QuartersDiff.java | 7 +-
.../expressions/functions/scalar/SecondsDiff.java | 3 +
.../expressions/functions/scalar/TimeDiff.java | 11 +
.../expressions/functions/scalar/WeeksDiff.java | 7 +-
.../expressions/functions/scalar/YearsDiff.java | 7 +-
.../trees/expressions/functions/udf/AliasUdf.java | 17 +-
.../trees/expressions/literal/JsonLiteral.java | 39 +-
.../nereids/trees/expressions/literal/Literal.java | 2 +-
.../expressions/literal/StringLikeLiteral.java | 12 +-
.../expressions/literal/TimestampTzLiteral.java | 38 ++
.../plans/commands/CreateFunctionCommand.java | 14 +-
.../commands/insert/AbstractInsertExecutor.java | 4 +-
.../trees/plans/commands/insert/InsertUtils.java | 2 +-
.../org/apache/doris/nereids/types/DataType.java | 23 +-
.../doris/nereids/util/TypeCoercionUtils.java | 47 +-
.../org/apache/doris/persist/gson/GsonUtils.java | 9 +-
.../apache/doris/planner/GroupCommitPlanner.java | 2 +-
.../doris/planner/RuntimeFilterGenerator.java | 2 +-
.../java/org/apache/doris/qe/QeProcessorImpl.java | 5 +
.../org/apache/doris/qe/QueryStatisticsItem.java | 18 +
.../apache/doris/qe/ResultReceiverConsumer.java | 7 +-
.../java/org/apache/doris/qe/SessionVariable.java | 38 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 19 +-
.../main/java/org/apache/doris/qe/VariableMgr.java | 2 +-
.../apache/doris/qe/runtime/QueryProcessor.java | 4 +
.../WorkloadRuntimeStatusMgr.java | 112 ++-
.../org/apache/doris/statistics/AnalysisJob.java | 15 +-
.../apache/doris/statistics/AnalysisManager.java | 27 +-
.../AnalyzeSkipException.java} | 31 +-
.../apache/doris/statistics/BaseAnalysisTask.java | 117 +++-
.../doris/statistics/ExternalAnalysisTask.java | 1 +
.../apache/doris/statistics/OlapAnalysisTask.java | 5 +
.../doris/statistics/StatisticConstants.java | 14 +
.../apache/doris/statistics/StatisticsCache.java | 22 +-
.../doris/analysis/StorageDescPersistTest.java | 88 +++
.../proc/CurrentQueryStatisticsProcDirTest.java | 89 +++
.../apache/doris/common/util/LocationPathTest.java | 2 +-
.../apache/doris/common/util/PathUtilsTest.java | 2 +
.../doris/common/util/SerializationUtilsTest.java | 2 +
.../datasource/iceberg/IcebergTransactionTest.java | 2 +-
.../property/ConnectorPropertiesUtilsTest.java | 2 +
.../doris/datasource/property/ParamRulesTest.java | 2 +
.../metastore/AliyunDLFBasePropertiesTest.java | 4 +-
.../IcebergAliyunDLFMetaStorePropertiesTest.java | 2 +-
.../property/storage/AzurePropertiesTest.java | 2 +-
.../property/storage/AzurePropertyUtilsTest.java | 2 +-
.../property/storage/COSPropertiesTest.java | 2 +-
.../property/storage/HdfsPropertiesTest.java | 2 +-
.../property/storage/HdfsPropertiesUtilsTest.java | 2 +-
.../storage/S3ConnectorPropertiesUtilsTest.java | 2 +-
.../StreamingInsertJobCheckDataQualityTest.java | 54 ++
.../apache/doris/job/manager/JobManagerTest.java | 40 ++
.../doris/mysql/authenticate/TestLogAppender.java | 77 +++
.../authenticate/ldap/LdapAuthenticatorTest.java | 28 +
.../mysql/authenticate/ldap/LdapClientTest.java | 65 ++
.../mysql/authenticate/ldap/LdapManagerTest.java | 31 +
.../rules/exploration/mv/EliminateJoinTest.java | 129 ++++
.../doris/nereids/trees/expressions/UdfTest.java | 31 +
.../trees/expressions/VarBinaryLiteralTest.java | 2 +-
.../trees/expressions/literal/JsonLiteralTest.java | 124 ++++
.../apache/doris/nereids/types/DataTypeTest.java | 54 ++
.../doris/nereids/util/TypeCoercionUtilsTest.java | 18 +
.../apache/doris/planner/HiveTableSinkTest.java | 2 +-
.../apache/doris/qe/NereidsCoordinatorTest.java | 2 +-
.../doris/qe/ResultReceiverConsumerTest.java | 10 +
.../doris/qe/StmtExecutorInternalQueryTest.java | 31 +
.../java/org/apache/doris/qe/VariableMgrTest.java | 46 ++
.../WorkloadRuntimeStatusMgrTest.java | 285 ++++++++
.../doris/statistics/AnalysisManagerTest.java | 96 +++
.../org/apache/doris/statistics/CacheTest.java | 4 +-
.../doris/statistics/HMSAnalysisTaskTest.java | 2 +-
.../doris/statistics/OlapAnalysisTaskTest.java | 122 ++++
.../doris/statistics/StatisticsCacheTest.java | 110 +++
fe/fe-foundation/DESIGN.md | 178 +++++
fe/fe-foundation/pom.xml | 78 +++
.../doris/foundation/format}/FormatOptions.java | 2 +-
.../property/ConnectorPropertiesUtils.java | 24 +-
.../foundation}/property/ConnectorProperty.java | 2 +-
.../doris/foundation}/property/ParamRules.java | 2 +-
.../property}/StoragePropertiesException.java | 2 +-
.../apache/doris/foundation/type}/ResultOr.java | 2 +-
.../org/apache/doris/foundation}/util/BitUtil.java | 2 +-
.../doris/foundation}/util/ByteBufferUtil.java | 2 +-
.../apache/doris/foundation}/util/PathUtils.java | 2 +-
.../doris/foundation}/util/SerializationUtils.java | 2 +-
fe/pom.xml | 6 +
fs_brokers/cdc_client/build.sh | 2 +-
.../cdcclient/service/PipelineCoordinator.java | 30 +-
.../source/reader/AbstractCdcSourceReader.java | 45 ++
.../source/reader/JdbcIncrementalSourceReader.java | 39 +-
.../source/reader/mysql/MySqlSourceReader.java | 58 +-
.../reader/postgres/PostgresSourceReader.java | 23 +
.../source/reader/AbstractCdcSourceReaderTest.java | 165 +++++
gensrc/script/gen_build_version.sh | 4 +-
gensrc/thrift/FrontendService.thrift | 26 +
gensrc/thrift/PaloInternalService.thrift | 13 +
.../data/arrow_flight_sql_p0/test_select.out | 8 +-
.../one_level_nestedtypes_with_s3data.out | 582 ++++++++--------
.../timestamptz/test_timestamptz_agg_functions.out | 13 +
.../timestamptz/test_timestamptz_array_index.out | 19 +
.../timestamptz/test_timestamptz_dst_fold.out | 17 +
.../timestamptz/test_timestamptz_max_min_by.out | 7 +
.../test_timestamptz_storage_agg_key.out | 9 +
.../timestamptz/test_timestamptz_utc_functions.out | 33 +
.../sql-functions/doc_date_functions_test.out | 2 +-
.../cdc/test_streaming_mysql_job_date_pk.out | 29 +
.../cdc/test_streaming_postgres_job_date_pk.out | 29 +
..._cdc_stream_postgres_checkpoint_restart_fe.out} | 0
.../datetime_functions/test_date_function_v2.out | 6 +-
.../mv/join_elim_p_f_key/join_elim_filter_edge.out | 5 +
.../adaptive_batch_size/adaptive_batch_size.out | 73 ++
.../data/query_p0/test_parquet_dict.out | 4 +
.../test_partial_update_complex_type.out | 8 +-
.../doc_mode/test_variant_cast_strict.out | 10 +
.../data/variant_p0/duplicate_json_path.json | 7 +
.../org/apache/doris/regression/suite/Suite.groovy | 31 +
.../doris/regression/suite/SuiteCluster.groovy | 33 +
.../suites/arrow_flight_sql_p0/test_select.groovy | 36 +-
.../test_complex_disallowed_subtypes.groovy | 77 +++
.../test_timestamptz_agg_functions.groovy | 59 ++
.../test_timestamptz_array_index.groovy | 83 +++
.../timestamptz/test_timestamptz_dst_fold.groovy | 103 +++
.../timestamptz/test_timestamptz_max_min_by.groovy | 67 ++
.../test_timestamptz_utc_functions.groovy | 183 +++++
.../hive/test_hive_analyze_long_string.groovy | 125 ++++
.../tvf/test_hdfs_parquet_group0.groovy | 4 +-
.../test_audit_log_internal_query_failure.groovy | 98 +++
.../test_skip_calc_between_segments.groovy | 3 +-
.../cdc/test_streaming_mysql_job_date_pk.groovy | 129 ++++
.../cdc/test_streaming_mysql_job_metrics.groovy | 13 +-
.../cdc/test_streaming_postgres_job_date_pk.groovy | 131 ++++
...dc_stream_postgres_checkpoint_restart_fe.groovy | 298 ++++++++
.../jsonb_p0/test_jsonb_keys_invalid_path.groovy | 26 +-
.../join_elim_p_f_key/join_elim_filter_edge.groovy | 79 +++
.../adaptive_batch_size/adaptive_batch_size.groovy | 208 ++++++
.../suites/query_p0/test_parquet_dict.groovy | 24 +-
.../suites/statistics/analyze_stats.groovy | 2 +-
.../statistics/test_analyze_long_string.groovy | 288 ++++++++
.../test_compact_multi_segments.groovy | 4 +
.../test_schema_change_add_key_column.groovy | 3 +
.../doc_mode/test_variant_cast_strict.groovy | 129 ++++
.../suites/variant_p0/duplicate_json_path.groovy | 106 +++
.../variant_p0/predefine/test_predefine_ddl.groovy | 6 +-
504 files changed, 14429 insertions(+), 3529 deletions(-)
create mode 100644 be/src/common/thread_safety_annotations.h
create mode 100644 be/src/storage/segment/adaptive_block_size_predictor.cpp
create mode 100644 be/src/storage/segment/adaptive_block_size_predictor.h
create mode 100644 be/src/util/block_budget.h
create mode 100644 be/test/common/block_budget_test.cpp
create mode 100644 be/test/core/data_type/data_type_insert_default_test.cpp
create mode 100644 be/test/format/csv/csv_reader_test.cpp
create mode 100644 be/test/format/json/json_reader_test.cpp
create mode 100644 be/test/runtime/runtime_state_block_budget_test.cpp
create mode 100644 be/test/storage/iterator/block_reader_agg_flush_test.cpp
create mode 100644
be/test/storage/iterator/block_reader_batch_max_rows_test.cpp
create mode 100644
be/test/storage/iterator/vcollect_iterator_collected_enough_test.cpp
create mode 100644
be/test/storage/segment/adaptive_block_size_predictor_test.cpp
create mode 100644
be/test/storage/segment/segment_column_raw_data_bytes_test.cpp
create mode 100644 be/test/storage/test_data/tablet_meta_test.hdr
create mode 100644 be/test/util/jsonb_contains_test.cpp
create mode 100644 be/test/util/test_data/stat_cpu_busy_after
create mode 100644 be/test/util/test_data/stat_cpu_busy_before
create mode 100644 be/test/util/test_data/stat_cpu_iowait_after
create mode 100644 be/test/util/test_data/stat_cpu_recovery_after
create mode 100644 be/test/util/test_data/stat_cpu_regressed_after
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/common/proc/CurrentQueryFragmentProcNode.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/common/proc/CurrentQueryInfoProvider.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/common/proc/CurrentQuerySqlProcDir.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/common/proc/CurrentQueryStatementsProcNode.java
copy fe/fe-core/src/main/java/org/apache/doris/{common/util/BitUtil.java =>
statistics/AnalyzeSkipException.java} (53%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/StorageDescPersistTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/proc/CurrentQueryStatisticsProcDirTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mysql/authenticate/TestLogAppender.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/literal/JsonLiteralTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/resource/workloadschedpolicy/WorkloadRuntimeStatusMgrTest.java
create mode 100644 fe/fe-foundation/DESIGN.md
create mode 100644 fe/fe-foundation/pom.xml
rename fe/{fe-core/src/main/java/org/apache/doris/common =>
fe-foundation/src/main/java/org/apache/doris/foundation/format}/FormatOptions.java
(98%)
rename fe/{fe-core/src/main/java/org/apache/doris/datasource =>
fe-foundation/src/main/java/org/apache/doris/foundation}/property/ConnectorPropertiesUtils.java
(91%)
rename fe/{fe-core/src/main/java/org/apache/doris/datasource =>
fe-foundation/src/main/java/org/apache/doris/foundation}/property/ConnectorProperty.java
(96%)
rename fe/{fe-core/src/main/java/org/apache/doris/datasource =>
fe-foundation/src/main/java/org/apache/doris/foundation}/property/ParamRules.java
(99%)
rename
fe/{fe-core/src/main/java/org/apache/doris/datasource/property/storage/exception
=>
fe-foundation/src/main/java/org/apache/doris/foundation/property}/StoragePropertiesException.java
(96%)
rename fe/{fe-common/src/main/java/org/apache/doris/common =>
fe-foundation/src/main/java/org/apache/doris/foundation/type}/ResultOr.java
(97%)
rename fe/{fe-core/src/main/java/org/apache/doris/common =>
fe-foundation/src/main/java/org/apache/doris/foundation}/util/BitUtil.java (97%)
rename fe/{fe-core/src/main/java/org/apache/doris/common =>
fe-foundation/src/main/java/org/apache/doris/foundation}/util/ByteBufferUtil.java
(96%)
rename fe/{fe-core/src/main/java/org/apache/doris/common =>
fe-foundation/src/main/java/org/apache/doris/foundation}/util/PathUtils.java
(98%)
rename fe/{fe-core/src/main/java/org/apache/doris/common =>
fe-foundation/src/main/java/org/apache/doris/foundation}/util/SerializationUtils.java
(98%)
create mode 100644
fs_brokers/cdc_client/src/test/java/org/apache/doris/cdcclient/source/reader/AbstractCdcSourceReaderTest.java
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_agg_functions.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_array_index.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_dst_fold.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_max_min_by.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_utc_functions.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_mysql_job_date_pk.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_postgres_job_date_pk.out
copy
regression-test/data/job_p0/streaming_job/cdc/tvf/{test_streaming_job_cdc_stream_postgres_restart_fe.out
=> test_streaming_job_cdc_stream_postgres_checkpoint_restart_fe.out} (100%)
create mode 100644
regression-test/data/nereids_rules_p0/mv/join_elim_p_f_key/join_elim_filter_edge.out
create mode 100644
regression-test/data/query_p0/adaptive_batch_size/adaptive_batch_size.out
create mode 100644 regression-test/data/query_p0/test_parquet_dict.out
create mode 100644
regression-test/data/variant_p0/doc_mode/test_variant_cast_strict.out
create mode 100644 regression-test/data/variant_p0/duplicate_json_path.json
create mode 100644
regression-test/suites/datatype_p0/complex_types/test_complex_disallowed_subtypes.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_agg_functions.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_array_index.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_dst_fold.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_max_min_by.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_utc_functions.groovy
create mode 100644
regression-test/suites/external_table_p0/hive/test_hive_analyze_long_string.groovy
create mode 100644
regression-test/suites/fault_injection_p0/test_audit_log_internal_query_failure.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_date_pk.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_date_pk.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_postgres_checkpoint_restart_fe.groovy
rename be/src/core/value/map_value.cpp =>
regression-test/suites/jsonb_p0/test_jsonb_keys_invalid_path.groovy (58%)
create mode 100644
regression-test/suites/nereids_rules_p0/mv/join_elim_p_f_key/join_elim_filter_edge.groovy
create mode 100644
regression-test/suites/query_p0/adaptive_batch_size/adaptive_batch_size.groovy
rename be/src/core/value/struct_value.cpp =>
regression-test/suites/query_p0/test_parquet_dict.groovy (60%)
create mode 100644
regression-test/suites/statistics/test_analyze_long_string.groovy
create mode 100644
regression-test/suites/variant_p0/doc_mode/test_variant_cast_strict.groovy
create mode 100644 regression-test/suites/variant_p0/duplicate_json_path.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
